[release] add timestamp,date & datetime data types support for mysql and postgres (#95)

SockworkOrange · web-flow · commit d154e40a5adf · 2024-12-13T19:54:42.000+01:00
diff --git a/Drivers/DbDriver.cs b/Drivers/DbDriver.cs
@@ -13,12 +13,15 @@ public abstract class DbDriver(DotnetFramework dotnetFramework)
 {
     public DotnetFramework DotnetFramework { get; } = dotnetFramework;
 
+    private HashSet<string> CsharpPrimitives { get; } = ["long", "double", "int", "float", "bool", "DateTime"];
+
     public virtual UsingDirectiveSyntax[] GetUsingDirectives()
     {
         return
         [
             UsingDirective(ParseName("System.Collections.Generic")),
-            UsingDirective(ParseName("System.Threading.Tasks"))
+            UsingDirective(ParseName("System.Threading.Tasks")),
+            UsingDirective(ParseName("System"))
         ];
     }
 
@@ -73,9 +76,8 @@ public abstract MemberDeclarationSyntax ManyDeclare(string sqlTextConstant, stri
 
     public abstract MemberDeclarationSyntax ExecDeclare(string text, string argInterface, Query query);
 
-    public static bool IsCsharpPrimitive(string csharpType)
+    public bool IsCsharpPrimitive(string csharpType)
     {
-        var csharpPrimitives = new HashSet<string> { "long", "double", "int", "float", "bool" };
-        return csharpPrimitives.Contains(csharpType.Replace("?", ""));
+        return CsharpPrimitives.Contains(csharpType.Replace("?", ""));
     }
 }
diff --git a/Drivers/Generators/CommonGen.cs b/Drivers/Generators/CommonGen.cs
@@ -55,7 +55,7 @@ string GetNullExpression(Column column)
             var csharpType = dbDriver.GetColumnType(column);
             if (csharpType == "string")
                 return "string.Empty";
-            return !dbDriver.DotnetFramework.LatestDotnetSupported() && DbDriver.IsCsharpPrimitive(csharpType)
+            return !dbDriver.DotnetFramework.LatestDotnetSupported() && dbDriver.IsCsharpPrimitive(csharpType)
                 ? $"({csharpType}) null"
                 : "null";
         }
diff --git a/Drivers/MySqlConnectorDriver.cs b/Drivers/MySqlConnectorDriver.cs
@@ -28,17 +28,19 @@ public partial class MySqlConnectorDriver(DotnetFramework dotnetFramework) : DbD
             ]),
             ("string", ordinal => $"reader.GetString({ordinal})", [
                 "char",
-                "date",
-                "datetime",
                 "decimal",
                 "longtext",
                 "mediumtext",
                 "text",
                 "time",
-                "timestamp",
                 "tinytext",
                 "varchar"
             ]),
+            ("DateTime", ordinal => $"reader.GetDateTime({ordinal})", [
+                "date",
+                "datetime",
+                "timestamp"
+            ]),
             ("int", ordinal => $"reader.GetInt32({ordinal})", [
                 "int",
                 "mediumint",
diff --git a/Drivers/NpgsqlDriver.cs b/Drivers/NpgsqlDriver.cs
@@ -29,18 +29,21 @@ public class NpgsqlDriver(DotnetFramework dotnetFramework) : DbDriver(dotnetFram
             ("string", ordinal => $"reader.GetString({ordinal})",
             [
                 "char",
-                "date",
-                "datetime",
+
                 "longtext",
                 "mediumtext",
                 "text",
                 "bpchar",
                 "time",
-                "timestamp",
                 "tinytext",
                 "varchar",
                 "pg_catalog.varchar"
             ]),
+            ("DateTime", ordinal => $"reader.GetDateTime({ordinal})", [
+                "date",
+                "datetime",
+                "timestamp"
+            ]),
             ("object", ordinal => $"reader.GetString({ordinal})", ["json"]),
             ("int", ordinal => $"reader.GetInt32({ordinal})", [
                 "integer",
diff --git a/EndToEndTests/MySqlConnectorTests.cs b/EndToEndTests/MySqlConnectorTests.cs
@@ -44,6 +44,11 @@ await QuerySql.CreateAuthor(new QuerySql.CreateAuthorArgs
             Bio: DataGenerator.DrSeussQuote
         }
         ]);
+
+        foreach (var a in actualAuthors)
+        {
+            Assert.That(a.Created >= DateTime.Now.Subtract(TimeSpan.FromSeconds(30)) && a.Created < DateTime.Now);
+        }
     }
 
     [Test]
diff --git a/EndToEndTests/NpgsqlTests.cs b/EndToEndTests/NpgsqlTests.cs
@@ -47,6 +47,11 @@ await QuerySql.CreateAuthor(new QuerySql.CreateAuthorArgs
             Bio: DataGenerator.DrSeussQuote
         }
         ]);
+
+        foreach (var a in actualAuthors)
+        {
+            Assert.That(a.Created >= DateTime.Now.Subtract(TimeSpan.FromSeconds(30)) && a.Created < DateTime.Now);
+        }
     }
 
     [Test]
diff --git a/MySqlConnectorExample/QuerySql.cs b/MySqlConnectorExample/QuerySql.cs
@@ -4,13 +4,14 @@
 // ReSharper disable InconsistentNaming
 using System.Collections.Generic;
 using System.Threading.Tasks;
+using System;
 using MySqlConnector;
 
 namespace MySqlConnectorExampleGen;
 public class QuerySql(string connectionString)
 {
-    private const string GetAuthorSql = "SELECT id, name, bio FROM authors WHERE name = @name LIMIT 1";
-    public readonly record struct GetAuthorRow(long Id, string Name, string? Bio);
+    private const string GetAuthorSql = "SELECT id, name, bio, created FROM authors WHERE name = @name LIMIT 1";
+    public readonly record struct GetAuthorRow(long Id, string Name, string? Bio, DateTime Created);
     public readonly record struct GetAuthorArgs(string Name);
     public async Task<GetAuthorRow?> GetAuthor(GetAuthorArgs args)
     {
@@ -26,16 +27,17 @@ public class QuerySql(string connectionString)
                 {
                     Id = reader.GetInt64(0),
                     Name = reader.GetString(1),
-                    Bio = reader.IsDBNull(2) ? null : reader.GetString(2)
+                    Bio = reader.IsDBNull(2) ? null : reader.GetString(2),
+                    Created = reader.GetDateTime(3)
                 };
             }
 
             return null;
         }
     }
 
-    private const string ListAuthorsSql = "SELECT id, name, bio FROM authors ORDER BY name";
-    public readonly record struct ListAuthorsRow(long Id, string Name, string? Bio);
+    private const string ListAuthorsSql = "SELECT id, name, bio, created FROM authors ORDER BY name";
+    public readonly record struct ListAuthorsRow(long Id, string Name, string? Bio, DateTime Created);
     public async Task<List<ListAuthorsRow>> ListAuthors()
     {
         {
@@ -46,7 +48,7 @@ public async Task<List<ListAuthorsRow>> ListAuthors()
             var result = new List<ListAuthorsRow>();
             while (await reader.ReadAsync())
             {
-                result.Add(new ListAuthorsRow { Id = reader.GetInt64(0), Name = reader.GetString(1), Bio = reader.IsDBNull(2) ? null : reader.GetString(2) });
+                result.Add(new ListAuthorsRow { Id = reader.GetInt64(0), Name = reader.GetString(1), Bio = reader.IsDBNull(2) ? null : reader.GetString(2), Created = reader.GetDateTime(3) });
             }
 
             return result;
@@ -121,7 +123,7 @@ public async Task TruncateAuthors()
     }
 
     private const string TestSql = "SELECT c_bit, c_tinyint, c_bool, c_boolean, c_smallint, c_mediumint, c_int, c_integer, c_bigint, c_serial, c_decimal, c_dec, c_numeric, c_fixed, c_float, c_double, c_double_precision, c_date, c_time, c_datetime, c_timestamp, c_year, c_char, c_nchar, c_national_char, c_varchar, c_binary, c_varbinary, c_tinyblob, c_tinytext, c_blob, c_text, c_mediumblob, c_mediumtext, c_longblob, c_longtext, c_json FROM node_mysql_types LIMIT 1";
-    public readonly record struct TestRow(byte[]? C_bit, int? C_tinyint, int? C_bool, int? C_boolean, int? C_smallint, int? C_mediumint, int? C_int, int? C_integer, long? C_bigint, long C_serial, string? C_decimal, string? C_dec, string? C_numeric, string? C_fixed, double? C_float, double? C_double, double? C_double_precision, string? C_date, string? C_time, string? C_datetime, string? C_timestamp, int? C_year, string? C_char, string? C_nchar, string? C_national_char, string? C_varchar, byte[]? C_binary, byte[]? C_varbinary, byte[]? C_tinyblob, string? C_tinytext, byte[]? C_blob, string? C_text, byte[]? C_mediumblob, string? C_mediumtext, byte[]? C_longblob, string? C_longtext, object? C_json);
+    public readonly record struct TestRow(byte[]? C_bit, int? C_tinyint, int? C_bool, int? C_boolean, int? C_smallint, int? C_mediumint, int? C_int, int? C_integer, long? C_bigint, long C_serial, string? C_decimal, string? C_dec, string? C_numeric, string? C_fixed, double? C_float, double? C_double, double? C_double_precision, DateTime? C_date, string? C_time, DateTime? C_datetime, DateTime? C_timestamp, int? C_year, string? C_char, string? C_nchar, string? C_national_char, string? C_varchar, byte[]? C_binary, byte[]? C_varbinary, byte[]? C_tinyblob, string? C_tinytext, byte[]? C_blob, string? C_text, byte[]? C_mediumblob, string? C_mediumtext, byte[]? C_longblob, string? C_longtext, object? C_json);
     public async Task<TestRow?> Test()
     {
         {
@@ -150,10 +152,10 @@ public async Task TruncateAuthors()
                     C_float = reader.IsDBNull(14) ? null : reader.GetDouble(14),
                     C_double = reader.IsDBNull(15) ? null : reader.GetDouble(15),
                     C_double_precision = reader.IsDBNull(16) ? null : reader.GetDouble(16),
-                    C_date = reader.IsDBNull(17) ? null : reader.GetString(17),
+                    C_date = reader.IsDBNull(17) ? null : reader.GetDateTime(17),
                     C_time = reader.IsDBNull(18) ? null : reader.GetString(18),
-                    C_datetime = reader.IsDBNull(19) ? null : reader.GetString(19),
-                    C_timestamp = reader.IsDBNull(20) ? null : reader.GetString(20),
+                    C_datetime = reader.IsDBNull(19) ? null : reader.GetDateTime(19),
+                    C_timestamp = reader.IsDBNull(20) ? null : reader.GetDateTime(20),
                     C_year = reader.IsDBNull(21) ? null : reader.GetInt32(21),
                     C_char = reader.IsDBNull(22) ? null : reader.GetString(22),
                     C_nchar = reader.IsDBNull(23) ? null : reader.GetString(23),
diff --git a/NpgsqlExample/QuerySql.cs b/NpgsqlExample/QuerySql.cs
@@ -4,13 +4,14 @@
 // ReSharper disable InconsistentNaming
 using System.Collections.Generic;
 using System.Threading.Tasks;
+using System;
 using Npgsql;
 
 namespace NpgsqlExampleGen;
 public class QuerySql(string connectionString)
 {
-    private const string GetAuthorSql = "SELECT id, name, bio FROM authors WHERE name = @name LIMIT 1";
-    public readonly record struct GetAuthorRow(long Id, string Name, string? Bio);
+    private const string GetAuthorSql = "SELECT id, name, bio, created FROM authors WHERE name = @name LIMIT 1";
+    public readonly record struct GetAuthorRow(long Id, string Name, string? Bio, DateTime Created);
     public readonly record struct GetAuthorArgs(string Name);
     public async Task<GetAuthorRow?> GetAuthor(GetAuthorArgs args)
     {
@@ -25,16 +26,17 @@ public class QuerySql(string connectionString)
                 {
                     Id = reader.GetInt64(0),
                     Name = reader.GetString(1),
-                    Bio = reader.IsDBNull(2) ? null : reader.GetString(2)
+                    Bio = reader.IsDBNull(2) ? null : reader.GetString(2),
+                    Created = reader.GetDateTime(3)
                 };
             }
 
             return null;
         }
     }
 
-    private const string ListAuthorsSql = "SELECT id, name, bio FROM authors ORDER BY name";
-    public readonly record struct ListAuthorsRow(long Id, string Name, string? Bio);
+    private const string ListAuthorsSql = "SELECT id, name, bio, created FROM authors ORDER BY name";
+    public readonly record struct ListAuthorsRow(long Id, string Name, string? Bio, DateTime Created);
     public async Task<List<ListAuthorsRow>> ListAuthors()
     {
         {
@@ -44,15 +46,15 @@ public async Task<List<ListAuthorsRow>> ListAuthors()
             var result = new List<ListAuthorsRow>();
             while (await reader.ReadAsync())
             {
-                result.Add(new ListAuthorsRow { Id = reader.GetInt64(0), Name = reader.GetString(1), Bio = reader.IsDBNull(2) ? null : reader.GetString(2) });
+                result.Add(new ListAuthorsRow { Id = reader.GetInt64(0), Name = reader.GetString(1), Bio = reader.IsDBNull(2) ? null : reader.GetString(2), Created = reader.GetDateTime(3) });
             }
 
             return result;
         }
     }
 
-    private const string CreateAuthorSql = "INSERT INTO authors (name, bio) VALUES (@name, @bio) RETURNING id, name, bio";
-    public readonly record struct CreateAuthorRow(long Id, string Name, string? Bio);
+    private const string CreateAuthorSql = "INSERT INTO authors (name, bio) VALUES (@name, @bio) RETURNING id, name, bio, created";
+    public readonly record struct CreateAuthorRow(long Id, string Name, string? Bio, DateTime Created);
     public readonly record struct CreateAuthorArgs(string Name, string? Bio);
     public async Task<CreateAuthorRow?> CreateAuthor(CreateAuthorArgs args)
     {
@@ -68,7 +70,8 @@ public async Task<List<ListAuthorsRow>> ListAuthors()
                 {
                     Id = reader.GetInt64(0),
                     Name = reader.GetString(1),
-                    Bio = reader.IsDBNull(2) ? null : reader.GetString(2)
+                    Bio = reader.IsDBNull(2) ? null : reader.GetString(2),
+                    Created = reader.GetDateTime(3)
                 };
             }
 
@@ -132,7 +135,7 @@ public async Task<long> UpdateAuthors(UpdateAuthorsArgs args)
     }
 
     private const string TestSql = "SELECT c_bit, c_smallint, c_boolean, c_integer, c_bigint, c_serial, c_decimal, c_numeric, c_real, c_double_precision, c_date, c_time, c_timestamp, c_char, c_varchar, c_character_varying, c_bytea, c_text, c_json FROM node_postgres_types LIMIT 1";
-    public readonly record struct TestRow(byte[]? C_bit, int? C_smallint, bool? C_boolean, int? C_integer, int? C_bigint, long? C_serial, float? C_decimal, float? C_numeric, float? C_real, float? C_double_precision, string? C_date, string? C_time, string? C_timestamp, string? C_char, string? C_varchar, string? C_character_varying, byte[]? C_bytea, string? C_text, object? C_json);
+    public readonly record struct TestRow(byte[]? C_bit, int? C_smallint, bool? C_boolean, int? C_integer, int? C_bigint, long? C_serial, float? C_decimal, float? C_numeric, float? C_real, float? C_double_precision, DateTime? C_date, string? C_time, DateTime? C_timestamp, string? C_char, string? C_varchar, string? C_character_varying, byte[]? C_bytea, string? C_text, object? C_json);
     public async Task<TestRow?> Test()
     {
         {
@@ -153,9 +156,9 @@ public async Task<long> UpdateAuthors(UpdateAuthorsArgs args)
                     C_numeric = reader.IsDBNull(7) ? null : reader.GetFloat(7),
                     C_real = reader.IsDBNull(8) ? null : reader.GetFloat(8),
                     C_double_precision = reader.IsDBNull(9) ? null : reader.GetFloat(9),
-                    C_date = reader.IsDBNull(10) ? null : reader.GetString(10),
+                    C_date = reader.IsDBNull(10) ? null : reader.GetDateTime(10),
                     C_time = reader.IsDBNull(11) ? null : reader.GetString(11),
-                    C_timestamp = reader.IsDBNull(12) ? null : reader.GetString(12),
+                    C_timestamp = reader.IsDBNull(12) ? null : reader.GetDateTime(12),
                     C_char = reader.IsDBNull(13) ? null : reader.GetString(13),
                     C_varchar = reader.IsDBNull(14) ? null : reader.GetString(14),
                     C_character_varying = reader.IsDBNull(15) ? null : reader.GetString(15),
diff --git a/SqliteExample/QuerySql.cs b/SqliteExample/QuerySql.cs
@@ -4,6 +4,7 @@
 // ReSharper disable InconsistentNaming
 using System.Collections.Generic;
 using System.Threading.Tasks;
+using System;
 using Microsoft.Data.Sqlite;
 using System;
 
diff --git a/examples/authors/mysql/schema.sql b/examples/authors/mysql/schema.sql
@@ -1,7 +1,8 @@
 CREATE TABLE authors (
-  id   BIGINT PRIMARY KEY AUTO_INCREMENT,
-  name text      NOT NULL,
-  bio  text
+  id      BIGINT    PRIMARY KEY AUTO_INCREMENT,
+  name    TEXT      NOT NULL,
+  bio     TEXT,
+  created TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 CREATE TABLE node_mysql_types (
diff --git a/examples/authors/postgresql/schema.sql b/examples/authors/postgresql/schema.sql
@@ -1,7 +1,8 @@
 CREATE TABLE authors (
-    id   BIGSERIAL PRIMARY KEY,
-    name text      NOT NULL,
-    bio  text
+    id      BIGSERIAL PRIMARY KEY,
+    name    TEXT      NOT NULL,
+    bio     TEXT,
+    created TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 CREATE TABLE node_postgres_types (

Original file line number	Diff line number	Diff line change
`@@ -13,12 +13,15 @@ public abstract class DbDriver(DotnetFramework dotnetFramework)`
`13`	`13`	`{`
`14`	`14`	`public DotnetFramework DotnetFramework { get; } = dotnetFramework;`
`15`	`15`
	`16`	`+ private HashSet<string> CsharpPrimitives { get; } = ["long", "double", "int", "float", "bool", "DateTime"];`
	`17`	`+`
`16`	`18`	`public virtual UsingDirectiveSyntax[] GetUsingDirectives()`
`17`	`19`	`{`
`18`	`20`	`return`
`19`	`21`	`[`
`20`	`22`	`UsingDirective(ParseName("System.Collections.Generic")),`
`21`		`- UsingDirective(ParseName("System.Threading.Tasks"))`
	`23`	`+ UsingDirective(ParseName("System.Threading.Tasks")),`
	`24`	`+ UsingDirective(ParseName("System"))`
`22`	`25`	`];`
`23`	`26`	`}`
`24`	`27`
`@@ -73,9 +76,8 @@ public abstract MemberDeclarationSyntax ManyDeclare(string sqlTextConstant, stri`
`73`	`76`
`74`	`77`	`public abstract MemberDeclarationSyntax ExecDeclare(string text, string argInterface, Query query);`
`75`	`78`
`76`		`- public static bool IsCsharpPrimitive(string csharpType)`
	`79`	`+ public bool IsCsharpPrimitive(string csharpType)`
`77`	`80`	`{`
`78`		`- var csharpPrimitives = new HashSet<string> { "long", "double", "int", "float", "bool" };`
`79`		`- return csharpPrimitives.Contains(csharpType.Replace("?", ""));`
	`81`	`+ return CsharpPrimitives.Contains(csharpType.Replace("?", ""));`
`80`	`82`	`}`
`81`	`83`	`}`
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ string GetNullExpression(Column column)`
`55`	`55`	`var csharpType = dbDriver.GetColumnType(column);`
`56`	`56`	`if (csharpType == "string")`
`57`	`57`	`return "string.Empty";`
`58`		`- return !dbDriver.DotnetFramework.LatestDotnetSupported() && DbDriver.IsCsharpPrimitive(csharpType)`
	`58`	`+ return !dbDriver.DotnetFramework.LatestDotnetSupported() && dbDriver.IsCsharpPrimitive(csharpType)`
`59`	`59`	`? $"({csharpType}) null"`
`60`	`60`	`: "null";`
`61`	`61`	`}`
Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,11 @@ await QuerySql.CreateAuthor(new QuerySql.CreateAuthorArgs`
`44`	`44`	`Bio: DataGenerator.DrSeussQuote`
`45`	`45`	`}`
`46`	`46`	`]);`
	`47`	`+`
	`48`	`+ foreach (var a in actualAuthors)`
	`49`	`+ {`
	`50`	`+ Assert.That(a.Created >= DateTime.Now.Subtract(TimeSpan.FromSeconds(30)) && a.Created < DateTime.Now);`
	`51`	`+ }`
`47`	`52`	`}`
`48`	`53`
`49`	`54`	`[Test]`
Original file line number	Diff line number	Diff line change
`@@ -47,6 +47,11 @@ await QuerySql.CreateAuthor(new QuerySql.CreateAuthorArgs`
`47`	`47`	`Bio: DataGenerator.DrSeussQuote`
`48`	`48`	`}`
`49`	`49`	`]);`
	`50`	`+`
	`51`	`+ foreach (var a in actualAuthors)`
	`52`	`+ {`
	`53`	`+ Assert.That(a.Created >= DateTime.Now.Subtract(TimeSpan.FromSeconds(30)) && a.Created < DateTime.Now);`
	`54`	`+ }`
`50`	`55`	`}`
`51`	`56`
`52`	`57`	`[Test]`
Original file line number	Diff line number	Diff line change
`@@ -4,13 +4,14 @@`
`4`	`4`	`// ReSharper disable InconsistentNaming`
`5`	`5`	`using System.Collections.Generic;`
`6`	`6`	`using System.Threading.Tasks;`
	`7`	`+using System;`
`7`	`8`	`using MySqlConnector;`
`8`	`9`
`9`	`10`	`namespace MySqlConnectorExampleGen;`
`10`	`11`	`public class QuerySql(string connectionString)`
`11`	`12`	`{`
`12`		`- private const string GetAuthorSql = "SELECT id, name, bio FROM authors WHERE name = @name LIMIT 1";`
`13`		`- public readonly record struct GetAuthorRow(long Id, string Name, string? Bio);`
	`13`	`+ private const string GetAuthorSql = "SELECT id, name, bio, created FROM authors WHERE name = @name LIMIT 1";`
	`14`	`+ public readonly record struct GetAuthorRow(long Id, string Name, string? Bio, DateTime Created);`
`14`	`15`	`public readonly record struct GetAuthorArgs(string Name);`
`15`	`16`	`public async Task<GetAuthorRow?> GetAuthor(GetAuthorArgs args)`
`16`	`17`	`{`
`@@ -26,16 +27,17 @@ public class QuerySql(string connectionString)`
`26`	`27`	`{`
`27`	`28`	`Id = reader.GetInt64(0),`
`28`	`29`	`Name = reader.GetString(1),`
`29`		`- Bio = reader.IsDBNull(2) ? null : reader.GetString(2)`
	`30`	`+ Bio = reader.IsDBNull(2) ? null : reader.GetString(2),`
	`31`	`+ Created = reader.GetDateTime(3)`
`30`	`32`	`};`
`31`	`33`	`}`
`32`	`34`
`33`	`35`	`return null;`
`34`	`36`	`}`
`35`	`37`	`}`
`36`	`38`
`37`		`- private const string ListAuthorsSql = "SELECT id, name, bio FROM authors ORDER BY name";`
`38`		`- public readonly record struct ListAuthorsRow(long Id, string Name, string? Bio);`
	`39`	`+ private const string ListAuthorsSql = "SELECT id, name, bio, created FROM authors ORDER BY name";`
	`40`	`+ public readonly record struct ListAuthorsRow(long Id, string Name, string? Bio, DateTime Created);`
`39`	`41`	`public async Task<List<ListAuthorsRow>> ListAuthors()`
`40`	`42`	`{`
`41`	`43`	`{`
`@@ -46,7 +48,7 @@ public async Task<List<ListAuthorsRow>> ListAuthors()`
`46`	`48`	`var result = new List<ListAuthorsRow>();`
`47`	`49`	`while (await reader.ReadAsync())`
`48`	`50`	`{`
`49`		`- result.Add(new ListAuthorsRow { Id = reader.GetInt64(0), Name = reader.GetString(1), Bio = reader.IsDBNull(2) ? null : reader.GetString(2) });`
	`51`	`+ result.Add(new ListAuthorsRow { Id = reader.GetInt64(0), Name = reader.GetString(1), Bio = reader.IsDBNull(2) ? null : reader.GetString(2), Created = reader.GetDateTime(3) });`
`50`	`52`	`}`
`51`	`53`
`52`	`54`	`return result;`
`@@ -121,7 +123,7 @@ public async Task TruncateAuthors()`
`121`	`123`	`}`
`122`	`124`
`123`	`125`	`private const string TestSql = "SELECT c_bit, c_tinyint, c_bool, c_boolean, c_smallint, c_mediumint, c_int, c_integer, c_bigint, c_serial, c_decimal, c_dec, c_numeric, c_fixed, c_float, c_double, c_double_precision, c_date, c_time, c_datetime, c_timestamp, c_year, c_char, c_nchar, c_national_char, c_varchar, c_binary, c_varbinary, c_tinyblob, c_tinytext, c_blob, c_text, c_mediumblob, c_mediumtext, c_longblob, c_longtext, c_json FROM node_mysql_types LIMIT 1";`
`124`		- public readonly record struct TestRow(byte[]? C_bit, int? C_tinyint, int? C_bool, int? C_boolean, int? C_smallint, int? C_mediumint, int? C_int, int? C_integer, long? C_bigint, long C_serial, string? C_decimal, string? C_dec, string? C_numeric, string? C_fixed, double? C_float, double? C_double, double? C_double_precision, string? C_date, string? C_time, string? C_datetime, string? C_timestamp, int? C_year, string? C_char, string? C_nchar, string? C_national_char, string? C_varchar, byte[]? C_binary, byte[]? C_varbinary, byte[]? C_tinyblob, string? C_tinytext, byte[]? C_blob, string? C_text, byte[]? C_mediumblob, string? C_mediumtext, byte[]? C_longblob, string? C_longtext, object? C_json);
	`126`	+ public readonly record struct TestRow(byte[]? C_bit, int? C_tinyint, int? C_bool, int? C_boolean, int? C_smallint, int? C_mediumint, int? C_int, int? C_integer, long? C_bigint, long C_serial, string? C_decimal, string? C_dec, string? C_numeric, string? C_fixed, double? C_float, double? C_double, double? C_double_precision, DateTime? C_date, string? C_time, DateTime? C_datetime, DateTime? C_timestamp, int? C_year, string? C_char, string? C_nchar, string? C_national_char, string? C_varchar, byte[]? C_binary, byte[]? C_varbinary, byte[]? C_tinyblob, string? C_tinytext, byte[]? C_blob, string? C_text, byte[]? C_mediumblob, string? C_mediumtext, byte[]? C_longblob, string? C_longtext, object? C_json);
`125`	`127`	`public async Task<TestRow?> Test()`
`126`	`128`	`{`
`127`	`129`	`{`
`@@ -150,10 +152,10 @@ public async Task TruncateAuthors()`
`150`	`152`	`C_float = reader.IsDBNull(14) ? null : reader.GetDouble(14),`
`151`	`153`	`C_double = reader.IsDBNull(15) ? null : reader.GetDouble(15),`
`152`	`154`	`C_double_precision = reader.IsDBNull(16) ? null : reader.GetDouble(16),`
`153`		`- C_date = reader.IsDBNull(17) ? null : reader.GetString(17),`
	`155`	`+ C_date = reader.IsDBNull(17) ? null : reader.GetDateTime(17),`
`154`	`156`	`C_time = reader.IsDBNull(18) ? null : reader.GetString(18),`
`155`		`- C_datetime = reader.IsDBNull(19) ? null : reader.GetString(19),`
`156`		`- C_timestamp = reader.IsDBNull(20) ? null : reader.GetString(20),`
	`157`	`+ C_datetime = reader.IsDBNull(19) ? null : reader.GetDateTime(19),`
	`158`	`+ C_timestamp = reader.IsDBNull(20) ? null : reader.GetDateTime(20),`
`157`	`159`	`C_year = reader.IsDBNull(21) ? null : reader.GetInt32(21),`
`158`	`160`	`C_char = reader.IsDBNull(22) ? null : reader.GetString(22),`
`159`	`161`	`C_nchar = reader.IsDBNull(23) ? null : reader.GetString(23),`