--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/servlib/storage/MysqlSQLImplementation.cc	Thu Apr 21 14:57:45 2011 +0100
@@ -0,0 +1,174 @@
+/*
+ *    Copyright 2004-2006 Intel Corporation
+ * 
+ *    Licensed under the Apache License, Version 2.0 (the "License");
+ *    you may not use this file except in compliance with the License.
+ *    You may obtain a copy of the License at
+ * 
+ *        http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ *    Unless required by applicable law or agreed to in writing, software
+ *    distributed under the License is distributed on an "AS IS" BASIS,
+ *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *    See the License for the specific language governing permissions and
+ *    limitations under the License.
+ */
+
+
+#ifdef HAVE_CONFIG_H
+#  include <dtn-config.h>
+#endif
+
+#if MYSQL_ENABLED
+
+#include <oasys/debug/DebugUtils.h>
+#include <oasys/debug/Log.h>
+
+#include "MysqlSQLImplementation.h"
+
+namespace dtn {
+
+MysqlSQLImplementation::MysqlSQLImplementation()
+    : SQLImplementation("BLOB", "BOOLEAN"),
+      Logger("/storage/mysql")
+{
+    query_result_ = NULL;
+}
+
+int
+MysqlSQLImplementation::connect(const char* dbName)
+{
+    db_ = mysql_init(NULL);
+
+    log_debug("connecting to database %s", dbName);
+ 
+    /* connect to database */
+    if (!mysql_real_connect(db_, NULL,
+                            NULL, NULL, dbName, 0, NULL, 0)) {
+        log_err("error connecting to database %s: %s",
+                dbName, mysql_error(db_));
+        return -1;
+    }
+
+    return 0;
+}
+
+const char*
+MysqlSQLImplementation::get_value(int tuple_no, int field_no)
+{
+    const char* ret;
+  
+    ASSERT(query_result_);
+    mysql_data_seek(query_result_, tuple_no);
+
+    MYSQL_ROW r = mysql_fetch_row(query_result_);
+    ret = r[field_no];
+    return ret;
+}
+
+/*
+size_t
+MysqlSQLImplementation::get_value_length(int tuple_no, int field_no)
+{
+    unsigned long *lengths;
+  
+    ASSERT(query_result_);
+    mysql_data_seek(query_result_, tuple_no);
+
+    mysql_fetch_row(query_result_);
+    lengths = mysql_fetch_lengths(query_result_);
+    return (size_t)lengths[field_no];
+}
+*/
+
+int
+MysqlSQLImplementation::close()
+{
+    mysql_close(db_);
+    db_ = NULL;
+    return 0;
+}
+
+bool
+MysqlSQLImplementation::has_table(const char* tablename)
+{
+    bool ret = false;
+ 
+    if (query_result_ != 0) {
+        mysql_free_result(query_result_);
+        query_result_ = 0;
+    }
+
+    query_result_ = mysql_list_tables(db_, tablename);
+    
+    if (mysql_num_rows(query_result_) == 1) {
+        ret = true;
+    }
+    
+    mysql_free_result(query_result_);
+    query_result_ = NULL;
+
+    return ret;
+}
+
+int
+MysqlSQLImplementation::num_tuples()
+{
+    int ret = -1;
+    ASSERT(query_result_);
+    ret = mysql_num_rows(query_result_);
+    return ret;
+}
+
+int
+MysqlSQLImplementation::exec_query(const char* query)
+{
+    int ret = -1;
+    
+    // free previous result state
+    if (query_result_ != NULL) {
+        mysql_free_result(query_result_);
+        query_result_ = NULL;
+    }
+    
+    ret = mysql_query(db_, query);
+    
+    if (ret == 1) {
+        return ret;
+    }
+    
+    query_result_ = mysql_store_result(db_);
+    
+    return ret;
+}
+
+const char* 
+MysqlSQLImplementation::escape_string(const char* from) 
+{
+    int length = strlen(from);
+    // XXX/demmer fix memory leaks
+    char* to = (char *) malloc(2*length+1);
+    mysql_real_escape_string(db_,to,from,length);
+
+    return to;
+}
+
+const u_char* 
+MysqlSQLImplementation::escape_binary(const u_char* from, int from_length) 
+{
+    int length = from_length;
+    // XXX/demmer fix memory leaks
+    char* to = (char *) malloc(2*length+1);
+    mysql_real_escape_string(db_,to,(const char*)from,length);
+    return (const u_char*) to;
+}
+
+const u_char* 
+MysqlSQLImplementation::unescape_binary(const u_char* from) 
+{
+    return from; 
+}
+
+} // namespace dtn
+
+#endif /* MYSQL_ENABLED */