Support emit_pointers_for_null_types in MySQL

internal/codegen/golang/mysql_type.go

@@ -13,20 +13,27 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 	columnType := sdk.DataType(col.Type)
 	notNull := col.NotNull || col.IsArray
 	unsigned := col.Unsigned
+	emitPointersForNull := options.EmitPointersForNullTypes
 
 	switch columnType {
 
 	case "varchar", "text", "char", "tinytext", "mediumtext", "longtext":
 		if notNull {
 			return "string"
 		}
+		if emitPointersForNull {
+			return "*string"
+		}
 		return "sql.NullString"
 
 	case "tinyint":
 		if col.Length == 1 {
 			if notNull {
 				return "bool"
 			}
+			if emitPointersForNull {
+				return "*bool"
+			}
 			return "sql.NullBool"
 		} else {
 			if notNull {
@@ -35,6 +42,12 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 				}
 				return "int8"
 			}
+			if emitPointersForNull {
+				if unsigned {
+					return "*uint8"
+				}
+				return "*int8"
+			}
 			// The database/sql package does not have a sql.NullInt8 type, so we
 			// use the smallest type they have which is NullInt16
 			return "sql.NullInt16"
@@ -44,6 +57,9 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 		if notNull {
 			return "int16"
 		}
+		if emitPointersForNull {
+			return "*int16"
+		}
 		return "sql.NullInt16"
 
 	case "smallint":
@@ -53,6 +69,12 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 			}
 			return "int16"
 		}
+		if emitPointersForNull {
+			if unsigned {
+				return "*uint16"
+			}
+			return "*int16"
+		}
 		return "sql.NullInt16"
 
 	case "int", "integer", "mediumint":
@@ -62,6 +84,12 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 			}
 			return "int32"
 		}
+		if emitPointersForNull {
+			if unsigned {
+				return "*uint32"
+			}
+			return "*int32"
+		}
 		return "sql.NullInt32"
 
 	case "bigint":
@@ -71,6 +99,12 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 			}
 			return "int64"
 		}
+		if emitPointersForNull {
+			if unsigned {
+				return "*uint64"
+			}
+			return "*int64"
+		}
 		return "sql.NullInt64"
 
 	case "blob", "binary", "varbinary", "tinyblob", "mediumblob", "longblob":
@@ -83,12 +117,18 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 		if notNull {
 			return "float64"
 		}
+		if emitPointersForNull {
+			return "*float64"
+		}
 		return "sql.NullFloat64"
 
 	case "decimal", "dec", "fixed":
 		if notNull {
 			return "string"
 		}
+		if emitPointersForNull {
+			return "*string"
+		}
 		return "sql.NullString"
 
 	case "enum":
@@ -99,12 +139,18 @@ func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.C
 		if notNull {
 			return "time.Time"
 		}
+		if emitPointersForNull {
+			return "*time.Time"
+		}
 		return "sql.NullTime"
 
 	case "boolean", "bool":
 		if notNull {
 			return "bool"
 		}
+		if emitPointersForNull {
+			return "*bool"
+		}
 		return "sql.NullBool"
 
 	case "json":

internal/endtoend/testdata/emit_pointers_for_null_types/mysql/sql/boolean.sql

@@ -0,0 +1,11 @@
+CREATE table dt_boolean (
+  a boolean,
+  b bool,
+  c tinyint(1)
+);
+
+CREATE table dt_boolean_not_null (
+  a boolean not null,
+  b bool not null,
+  c tinyint(1) not null
+);

internal/endtoend/testdata/emit_pointers_for_null_types/mysql/sql/integer.sql

@@ -0,0 +1,36 @@
+CREATE TABLE dt_integer (
+    a tinyint,
+    b smallint,
+    c int,
+    d integer,
+    e mediumint,
+    f bigint
+);
+
+CREATE TABLE dt_integer_not_null (
+    a tinyint not null,
+    b smallint not null,
+    c int not null,
+    d integer not null,
+    e mediumint not null,
+    f bigint not null
+);
+
+CREATE TABLE dt_unsigned_integer (
+    a tinyint unsigned,
+    b smallint unsigned,
+    c int unsigned,
+    d integer unsigned,
+    e mediumint unsigned,
+    f bigint unsigned
+);
+
+
+CREATE TABLE dt_unsigned_integer_not_null (
+    a tinyint unsigned not null,
+    b smallint unsigned not null,
+    c int unsigned not null,
+    d integer unsigned not null,
+    e mediumint unsigned not null,
+    f bigint unsigned not null
+);

internal/endtoend/testdata/emit_pointers_for_null_types/mysql/sql/query.sql

@@ -0,0 +1,2 @@
+-- name: Test :one
+SELECT 1;

internal/endtoend/testdata/emit_pointers_for_null_types/mysql/sql/real_number.sql

@@ -0,0 +1,19 @@
+CREATE TABLE dt_real_number (
+	a double,
+  b double precision,
+  c real,
+  d float,
+  e decimal,
+  f dec,
+  g fixed
+);
+
+CREATE TABLE dt_real_number_not_null (
+  a double not null,
+  b double precision not null,
+  c real not null,
+  d float not null,
+  e decimal not null,
+  f dec not null,
+  g fixed not null
+);

internal/endtoend/testdata/emit_pointers_for_null_types/mysql/sqlc.json

@@ -0,0 +1,13 @@
+{
+  "version": "1",
+  "packages": [
+    {
+      "path": "go",
+      "engine": "mysql",
+      "name": "datatype",
+      "schema": "sql/",
+      "queries": "sql/",
+      "emit_pointers_for_null_types": true
+    }
+  ]
+}