From de7f09985529d8d8ea492686c87d070469d20069 Mon Sep 17 00:00:00 2001
From: guy <guy@c028cbd2-c16b-5b4b-a496-9718f37d4682>
Date: Tue, 24 Jun 2014 12:45:40 +0000
Subject: [PATCH] Aggiunto supporto per SQLite3 in dll dinamica

git-svn-id: svn://10.65.10.50/branches/R_10_00@22966 c028cbd2-c16b-5b4b-a496-9718f37d4682
---
 xvaga/xvt.h       |   9 ++
 xvaga/xvt_sql.cpp | 277 ++++++++++++++++++++++++++++++++++++++++++++++
 xvaga/xvt_type.h  |   1 +
 3 files changed, 287 insertions(+)
 create mode 100644 xvaga/xvt_sql.cpp

diff --git a/xvaga/xvt.h b/xvaga/xvt.h
index eb9d1ffbe..f78e2487e 100755
--- a/xvaga/xvt.h
+++ b/xvaga/xvt.h
@@ -495,6 +495,15 @@ XVTDLL BOOLEAN  xvt_odbc_free_connection(XVT_ODBC handle);
 XVTDLL ULONG    xvt_odbc_execute(XVT_ODBC handle, const char* sql, ODBC_CALLBACK cb, void* jolly);
 XVTDLL BOOLEAN  xvt_odbc_driver(XVT_ODBC handle, char* str, int max_size);
 
+XVTDLL BOOLEAN   xvt_sql_close(XVT_SQLDB handle);
+XVTDLL BOOLEAN   xvt_sql_driver(XVT_SQLDB handle, char* str, int max_size);
+XVTDLL ULONG     xvt_sql_execute(XVT_SQLDB handle, const char* sql, ODBC_CALLBACK cb, void* jolly);
+XVTDLL SLIST     xvt_sql_list_fields(XVT_SQLDB handle, const char* table);
+XVTDLL SLIST     xvt_sql_list_tables(XVT_SQLDB handle);
+XVTDLL XVT_SQLDB xvt_sql_open(const char* dsn, const char* usr, const char* pwd, const char* dir);
+XVTDLL BOOLEAN   xvt_sql_table_exists(XVT_SQLDB handle, const char* name);
+
+
 typedef BOOLEAN PROP_CALLBACK(WINDOW win, XVT_TREEVIEW_NODE node, void* app_data);
 XVTDLL XVT_TREEVIEW_NODE xvt_prop_add(WINDOW win, const char* type, const char* name, const char* value, const char* label);
 XVTDLL XVT_TREEVIEW_NODE xvt_prop_current(WINDOW win);
diff --git a/xvaga/xvt_sql.cpp b/xvaga/xvt_sql.cpp
new file mode 100644
index 000000000..257f6fa9e
--- /dev/null
+++ b/xvaga/xvt_sql.cpp
@@ -0,0 +1,277 @@
+#include "wxinc.h"
+#include "xvt.h"
+
+#include "../wxSqlite3/wxSqlite3.h"
+
+class XVT_SQLDataBase
+{
+public:
+  virtual bool Open(const char* dsn, const char* usr, const char* pwd, const char* dir) = 0;
+  virtual bool Close() = 0 { return false; }
+  virtual bool IsOk() const = 0 { return false; }
+  virtual ULONG Execute(const char* sql, ODBC_CALLBACK cb, void* jolly) = 0;
+  virtual SLIST ListFields(const char* table) const = 0;
+  virtual SLIST ListTables() const = 0;
+  virtual bool TableExists(const char* name) const;
+
+  virtual ~XVT_SQLDataBase() { Close(); }
+};
+
+bool XVT_SQLDataBase::TableExists(const char* name) const
+{
+  bool yes = false;
+  SLIST list = ListTables();
+  for (SLIST_ELT e = xvt_slist_get_first(list); e != NULL && !yes; e = xvt_slist_get_next(list, e))
+  {
+    const char* table = xvt_slist_get(list, e, NULL);
+    yes = xvt_str_compare_ignoring_case(name, table) == 0;
+  }
+  xvt_slist_destroy(list);
+
+  return yes;
+}
+
+class XVT_SQLDB_SQLite3 : public XVT_SQLDataBase
+{
+  wxSQLite3Database* m_pDB;
+
+protected:
+  virtual bool Open(const char* dsn, const char* usr, const char* pwd, const char* dir);
+  virtual bool Close();
+  virtual bool IsOk() const { return m_pDB != NULL && m_pDB->IsOpen(); }
+  virtual ULONG Execute(const char* sql, ODBC_CALLBACK cb, void* jolly);
+  virtual SLIST ListFields(const char* table) const;
+  virtual SLIST ListTables() const;
+  virtual bool TableExists(const char* name) const;
+
+public:
+  XVT_SQLDB_SQLite3() : m_pDB(NULL) {}
+};
+
+bool XVT_SQLDB_SQLite3::Open(const char* dsn, const char*, const char*, const char*)
+{
+  Close();
+  m_pDB = new wxSQLite3Database;
+  if (dsn == NULL || *dsn <= ' ')
+    dsn = ":memory:";
+  try
+  {
+    m_pDB->Open(dsn);
+  }
+  catch(wxSQLite3Exception& e)
+  {
+    xvt_dm_post_error(e.GetMessage());
+    return false;
+  }
+
+  return true;
+}
+
+bool XVT_SQLDB_SQLite3::Close()
+{
+  if (IsOk())
+  {
+    delete m_pDB;
+    m_pDB = NULL;
+  }
+  return true;
+}
+
+ULONG XVT_SQLDB_SQLite3::Execute(const char* sql, ODBC_CALLBACK cb, void* jolly)
+{
+  ULONG nRows = 0;
+  if (!IsOk())
+    return nRows;
+
+  if (cb != NULL) // Ho una vera callback?
+  {
+    try
+    {
+      wxSQLite3ResultSet rs = m_pDB->ExecuteQuery(sql);
+      const short numcols = rs.GetColumnCount();
+
+      if (numcols > 0)
+      {
+        char** values = new char*[numcols];  // Lista dei valori del record corrente 
+        memset(values, 0, numcols*sizeof(char*));
+    
+        char** names = new char*[numcols*2]; // Lista dei nomi dei campi e dei tipi
+        memset(names, 0, numcols*2*sizeof(char*));
+
+        short c;
+        for (c = 0; c < numcols; c++)
+        {
+          names[c] = (char*)(const char*)rs.GetColumnName(c);
+          switch (rs.GetColumnType(c))
+          {
+          case WXSQLITE_INTEGER: 
+          case WXSQLITE_FLOAT: 
+            names[c+numcols] = "NUMERIC"; break;
+          default: 
+            names[c+numcols] = "VARCHAR"; break;
+          }
+        }
+
+        while (rs.NextRow())
+        {
+          for (c = 0; c < numcols; c++)
+            values[c] = (char*)(const char*)rs.GetAsString(c);
+          if (cb(jolly, numcols, values, names) != 0)
+            break;
+          nRows++;
+        }
+
+        delete values;   // butta la lista dei valori
+        delete names;    // butta la lista dei nomi
+      }
+    }
+    catch(wxSQLite3Exception& e)
+    {
+      xvt_dm_post_error(e.GetMessage() + "\n" + sql);
+    }
+  }
+  else
+    nRows = m_pDB->ExecuteUpdate(sql);
+
+  return nRows;
+}
+
+SLIST XVT_SQLDB_SQLite3::ListTables() const
+{
+  wxASSERT(m_pDB != NULL);
+  SLIST list = xvt_slist_create();
+  const wxString strQuery = wxT("SELECT name FROM sqlite_master WHERE type = 'table'");
+  try
+  {
+    wxSQLite3ResultSet rs = m_pDB->ExecuteQuery(strQuery);
+    while (rs.NextRow())
+      xvt_slist_add_at_elt(list, NULL, rs.GetAsString(0), 0L);
+  }
+  catch(wxSQLite3Exception& e)
+  {
+    xvt_dm_post_error(e.GetMessage() + "\n" + strQuery);
+  }
+  return list;
+}
+
+SLIST XVT_SQLDB_SQLite3::ListFields(const char* strTable) const
+{
+  SLIST list = NULL;
+  if (TableExists(strTable))
+  {
+    list = xvt_slist_create();
+    wxString strQuery; strQuery << "PRAGMA table_info(" << (const char*)strTable << ");";
+    try
+    {
+      wxSQLite3ResultSet rs = m_pDB->ExecuteQuery(strQuery);
+      while (rs.NextRow())
+      {
+        const wxString strField = rs.GetAsString(1);
+        const wxString strType  = rs.GetAsString(2);
+        if (strType == "INTEGER")
+          xvt_slist_add_at_elt(list, NULL, strField, 2L); // intfld
+        if (strType == "NUMERIC")
+          xvt_slist_add_at_elt(list, NULL, strField, 5L); // realfld 
+        else
+          xvt_slist_add_at_elt(list, NULL, strField, 1L); // alfafld
+      }
+    }
+    catch(wxSQLite3Exception& e)
+    {
+      xvt_dm_post_error(e.GetMessage() + "\n" + strQuery);
+    }
+  }
+  return list;
+}
+
+bool XVT_SQLDB_SQLite3::TableExists(const char* name) const
+{
+  return m_pDB != NULL && name && *name && m_pDB->TableExists(name);
+}
+
+///////////////////////////////////////////////////////////
+// xvt_sql_...
+///////////////////////////////////////////////////////////
+
+XVT_SQLDB xvt_sql_open(const char* dsn, const char* usr, const char* pwd, const char* dir)
+{
+  XVT_SQLDataBase* db = new XVT_SQLDB_SQLite3;
+  db->Open(dsn, usr, pwd, dir);
+  return (XVT_SQLDB)db;
+}
+
+BOOLEAN xvt_sql_close(XVT_SQLDB handle)
+{
+  BOOLEAN ok = handle != NULL;
+  if (ok)
+  {
+    XVT_SQLDataBase* db = (XVT_SQLDataBase*)handle;
+    if (db != NULL)
+      delete db;
+  }
+  return ok;
+}
+
+ULONG xvt_sql_execute(XVT_SQLDB handle, const char* sql, ODBC_CALLBACK cb, void* jolly)
+{
+  ULONG n = 0;
+  if (handle && sql && *sql)
+  {
+    XVT_SQLDataBase* db = (XVT_SQLDataBase*)handle;
+    if (db->IsOk())
+    {
+      try
+      {
+        n = db->Execute(sql, cb, jolly);
+      }
+      catch(wxSQLite3Exception& e)
+      {
+        xvt_dm_post_error(e.GetMessage() + "\n" + sql);
+      }
+    }
+  }  
+  return n;
+}
+
+SLIST xvt_sql_list_fields(XVT_SQLDB handle, const char* table)
+{
+  SLIST list = NULL;
+  XVT_SQLDataBase* db = (XVT_SQLDataBase*)handle;
+  if (table && *table && db != NULL && db->IsOk())
+    list = db->ListFields(table);
+  return list;
+}
+
+SLIST xvt_sql_list_tables(XVT_SQLDB handle)
+{
+  SLIST list = NULL;
+  XVT_SQLDataBase* db = (XVT_SQLDataBase*)handle;
+  if (db != NULL && db->IsOk())
+    list = db->ListTables();
+  return list;
+}
+
+BOOLEAN xvt_sql_table_exists(XVT_SQLDB handle, const char* name)
+{
+  BOOLEAN yes = FALSE;
+  if (handle && name && *name)
+  {
+    const XVT_SQLDataBase* db = (XVT_SQLDataBase*)handle;
+    if (db->IsOk())
+      yes = db->TableExists(name);
+  }
+  return yes;
+}
+
+
+BOOLEAN xvt_sql_driver(XVT_SQLDB handle, char* str, int max_size) 
+{ 
+  if (str != NULL && max_size > 8)
+  {
+    if (handle != NULL)
+      wxStrncpy(str, "SQLite 3", max_size);
+    else
+      wxStrncpy(str, "ODBC 2.0", max_size);
+  }
+  return handle != NULL; 
+}
diff --git a/xvaga/xvt_type.h b/xvaga/xvt_type.h
index 70af3631f..0225aa929 100755
--- a/xvaga/xvt_type.h
+++ b/xvaga/xvt_type.h
@@ -19,6 +19,7 @@ typedef unsigned int UNIT_TYPE;
 typedef unsigned long ULONG;
 typedef unsigned long XVT_ERRMSG;
 typedef unsigned long XVT_ODBC;
+typedef unsigned long XVT_SQLDB;
 
 typedef wchar_t XVT_WCHAR;
 typedef short MENU_TAG;