freetds date out(WIP), Impl->Driver

statement state var, oracle bind functions (WIP)

Author: cruisercoder

freetds/test.d

@@ -11,10 +11,23 @@ unittest {
     alias DB = Database!DefaultPolicy;
     testAll!DB("freetds");
 
+    dateTest();
     //example();
     //backTest();
 }
 
+void dateTest() {
+    import std.database.freetds;
+    import std.datetime;
+    auto db = createDatabase("freetds");
+    auto con = db.connection();
+    con.query("drop table d1");
+    con.query("create table d1(a date)");
+    con.query("insert into d1 values ('2016-01-15')");
+    auto rs = con.query("select * from d1");
+    writeResult(rs[]);
+}
+
 void example() {
     import std.database.freetds;
     //auto db = createDatabase("freetds://server/test?username=sa&password=admin");

mysql/test.d

@@ -10,6 +10,16 @@ unittest {
     import std.database.testsuite;
     alias DB = Database!DefaultPolicy;
     testAll!DB("mysql");
+
+    //negativeNotExecuteTest();
+
+}
+
+void negativeNotExecuteTest() {
+    auto db = createDatabase("mysql://127.0.0.1/test");
+    auto con = db.connection();
+    //con.statement("select * from score").writeResult();
+    con.statement("select * from score").writeResult();
 }
 
 unittest {

src/std/database/freetds/bindings.d

@@ -69,13 +69,54 @@ extern(System) {
         SYBFLTN = 109,
         SYBMONEYN = 110,
         SYBDATETIMN = 111,
-        SYBNVARCHAR = 103
+        SYBNVARCHAR = 103,
+
+        SYBMSDATE = 40
     };
 
     enum {
         NTBSTRINGBIND = 2,
+        DATETIMEBIND = 11
+    }
+
+    struct DBDATETIME {
+        DBINT dtdays;
+        DBINT dttime;
     }
 
+    struct tds_microsoft_dbdaterec {
+        DBINT year;     /* 1753 - 9999         */
+        DBINT quarter;      /* 1 - 4           */
+        DBINT month;        /* 1 - 12          */
+        DBINT day;      /* 1 - 31          */
+        DBINT dayofyear;    /* 1 - 366         */
+        DBINT week;             /* 1 - 54 (for leap years) */
+        DBINT weekday;      /* 1 - 7 (Mon. - Sun.)     */
+        DBINT hour;     /* 0 - 23          */
+        DBINT minute;       /* 0 - 59          */
+        DBINT second;       /* 0 - 59          */
+        DBINT millisecond;  /* 0 - 999         */
+        DBINT tzone;        /* -840 - 840          */
+    };
+
+    struct tds_microsoft_dbdaterec2 {
+        DBINT year;		/* 1753 - 9999  	   */
+        DBINT quarter;		/* 1 - 4 		   */
+        DBINT month;		/* 1 - 12 		   */
+        DBINT day;		/* 1 - 31 		   */
+        DBINT dayofyear;	/* 1 - 366 		   */
+        DBINT week;            	/* 1 - 54 (for leap years) */
+        DBINT weekday;		/* 1 - 7 (Mon. - Sun.)     */
+        DBINT hour;		/* 0 - 23 		   */
+        DBINT minute;		/* 0 - 59 		   */
+        DBINT second;		/* 0 - 59 		   */
+        DBINT nanosecond;	/* 0 - 999999999	   */
+        DBINT tzone;		/* 0 - 127  (Sybase only)  */
+    };
+
+    alias tds_microsoft_dbdaterec  DBDATEREC;
+    alias tds_microsoft_dbdaterec2 DBDATEREC2;
+
     RETCODE dbinit();
     void dbexit();
 
@@ -128,6 +169,10 @@ extern(System) {
 
     STATUS dbnextrow(DBPROCESS * dbproc);
 
+    // date functions
+    RETCODE dbdatecrack(DBPROCESS * dbproc, DBDATEREC * di, DBDATETIME * dt);
+    RETCODE dbanydatecrack(DBPROCESS * dbproc, DBDATEREC2 * di, int type, const void *data);
+
     // tds functions (from tds.h), not accessible from dblib :)
     alias ubyte TDS_TINYINT;
 

src/std/database/freetds/database.d

@@ -14,21 +14,21 @@ import std.typecons;
 import std.container.array;
 import std.experimental.logger;
 public import std.database.allocator;
-import std.database.impl;
+import std.database.front;
 import std.datetime;
 
 struct DefaultPolicy {
     alias Allocator = MyMallocator;
 }
 
-alias Database(T) = BasicDatabase!(Impl!T,T);
+alias Database(T) = BasicDatabase!(Driver!T,T);
 
 auto createDatabase()(string defaultURI="") {
     return Database!DefaultPolicy(defaultURI);  
 }
 
 
-struct Impl(Policy) {
+struct Driver(Policy) {
     alias Allocator = Policy.Allocator;
 
     private static bool isError(RETCODE ret) {
@@ -124,7 +124,7 @@ struct Impl(Policy) {
             db = db_;
             source = source_;
 
-            info("Connection: ");
+            //info("Connection: ");
 
             login = check("dblogin", dblogin());
 
@@ -150,7 +150,7 @@ struct Impl(Policy) {
         }
 
         ~this() {
-            info("~Connection: ", source);
+            //info("~Connection: ", source);
             if (con) dbclose(con);
             if (login) dbloginfree(login);
         }
@@ -292,6 +292,12 @@ struct Impl(Policy) {
                         allocSize = b.size+1;
                         b.bindType = NTBSTRINGBIND;
                         break;
+                    case SYBMSDATE:
+                        b.type = ValueType.Date;
+                        b.size = DBDATETIME.sizeof;
+                        allocSize = b.size;
+                        b.bindType = DATETIMEBIND;
+                        break;
                     default: 
                         b.type = ValueType.String;
                         b.size = 255;
@@ -348,7 +354,10 @@ struct Impl(Policy) {
         }
 
         auto get(X:Date)(Bind *b) {
-            return Date(2016,1,1); // fix
+            auto ptr = cast(DBDATETIME*) b.data.ptr;
+            DBDATEREC d;
+            check("dbdatecrack", dbdatecrack(dbproc, &d, ptr));
+            return Date(d.year, d.month, d.day);
         }
 
         void checkType(int a, int b) {