ODBC cleanup, Impl NS (WIP), freeTDS (WIP)

default source handled in front end

Author: cruisercoder

src/std/database/exception.d

@@ -1,10 +1,18 @@
 module std.database.exception;
 import std.exception;
 
+struct DatabaseError {
+    string message;
+}
+
 class DatabaseException : Exception {
     this(string msg, string file = __FILE__, size_t line = __LINE__) {
         super(msg, file, line);
     }
+
+    this(ref DatabaseError error, string msg, string file = __FILE__, size_t line = __LINE__) {
+        super(msg ~ ": " ~ error.message, file, line);
+    }
 }
 
 class ConnectionException : DatabaseException {

src/std/database/freetds/bindings.d

@@ -0,0 +1,130 @@
+module std.database.freetds.bindings;
+import core.stdc.config;
+
+extern(System) {
+    alias RETCODE = int;
+
+    alias int DBINT;
+    alias ubyte BYTE;
+    alias int STATUS;
+
+    enum {
+        REG_ROW = -1,
+        MORE_ROWS = -1,
+        NO_MORE_ROWS = -2,
+        BUF_FULL = -3,
+        NO_MORE_RESULTS = 2,
+        SUCCEED = 1,
+        FAIL = 0
+    }
+
+    enum {
+        INT_EXIT = 0,
+        INT_CONTINUE = 1,
+        INT_CANCEL = 2,
+        INT_TIMEOUT = 3
+    }
+
+    enum {
+        DBSETHOST = 1, /* this sets client host name */
+        DBSETUSER = 2,
+        DBSETPWD = 3,
+        DBSETHID = 4,       /* not implemented */
+        DBSETAPP = 5,
+        DBSETBCP = 6,
+        DBSETNATLANG = 7,
+        DBSETNOSHORT = 8,	/* not implemented */
+        DBSETHIER = 9,      /* not implemented */
+        DBSETCHARSET = 10,
+        DBSETPACKET = 11,
+        DBSETENCRYPT = 12,
+        DBSETLABELED = 13,
+        DBSETDBNAME = 14
+    }
+
+    enum {
+        SYBCHAR = 47,
+        SYBVARCHAR = 39,
+        SYBINTN = 38,
+        SYBINT1 = 48,
+        SYBINT2 = 52,
+        SYBINT4 = 56,
+        SYBINT8 = 127,
+        SYBFLT8 = 62,
+        SYBDATETIME = 61,
+        SYBBIT = 50,
+        SYBBITN = 104,
+        SYBTEXT = 35,
+        SYBNTEXT = 99,
+        SYBIMAGE = 34,
+        SYBMONEY4 = 122,
+        SYBMONEY = 60,
+        SYBDATETIME4 = 58,
+        SYBREAL = 59,
+        SYBBINARY = 45,
+        SYBVOID = 31,
+        SYBVARBINARY = 37,
+        SYBNUMERIC = 108,
+        SYBDECIMAL = 106,
+        SYBFLTN = 109,
+        SYBMONEYN = 110,
+        SYBDATETIMN = 111,
+        SYBNVARCHAR = 103
+    };
+
+    enum {
+        NTBSTRINGBIND = 2,
+    }
+
+    RETCODE dbinit();
+    void dbexit();
+
+    alias EHANDLEFUNC = int function(DBPROCESS *dbproc, int severity, int dberr, int oserr, char *dberrstr, char *oserrstr);
+
+    alias MHANDLEFUNC = int function(DBPROCESS *dbproc, DBINT msgno, int msgstate, int severity, char *msgtext, char *srvname,
+            char *proc, int line);
+
+    void dbsetuserdata(DBPROCESS * dbproc, BYTE * ptr);
+    BYTE *dbgetuserdata(DBPROCESS * dbproc);
+
+    EHANDLEFUNC dberrhandle(EHANDLEFUNC handler);
+    MHANDLEFUNC dbmsghandle(MHANDLEFUNC handler);
+
+    struct LOGINREC;
+    alias tds_dblib_loginrec = LOGINREC;
+
+    LOGINREC *dblogin();
+    void dbloginfree(LOGINREC * login);
+
+    RETCODE dbsetlname(LOGINREC * login, const char *value, int which);
+
+    struct DBPROCESS;
+    alias tds_dblib_dbprocess = DBPROCESS;
+
+    DBPROCESS *dbopen(LOGINREC * login, const char *server);
+    DBPROCESS *tdsdbopen(LOGINREC * login, const char *server, int msdblib);
+    void dbclose(DBPROCESS * dbproc);
+
+    RETCODE dbuse(DBPROCESS* dbproc, const char *name);
+
+    // something about array def is a problem
+    //RETCODE dbcmd(DBPROCESS * dbproc, const char[] cmdstring);
+    RETCODE dbcmd(DBPROCESS * dbproc, const char* cmdstring);
+
+    RETCODE dbsqlexec(DBPROCESS * dbproc);
+
+    RETCODE dbresults(DBPROCESS * dbproc);
+    int dbnumcols(DBPROCESS * dbproc);
+
+    char *dbcolname(DBPROCESS * dbproc, int column);
+    int dbcoltype(DBPROCESS * dbproc, int column);
+    DBINT dbcollen(DBPROCESS * dbproc, int column);
+
+    RETCODE dbbind(DBPROCESS * dbproc, int column, int vartype, DBINT varlen, BYTE * varaddr);
+    RETCODE dbnullbind(DBPROCESS * dbproc, int column, DBINT * indicator);
+
+    STATUS dbnextrow(DBPROCESS * dbproc);
+
+}
+
+