Skip to content

Commit d0fcb2a

Browse files
JilleJille
authored
feat(mysql): Support json.RawMessage for LOAD DATA INFILE (sqlc-dev#3099)
1 parent 550c93d commit d0fcb2a

File tree

5 files changed

+66
-1
lines changed

5 files changed

+66
-1
lines changed

‎internal/codegen/golang/templates/go-sql-driver-mysql/copyfromCopy.tmpl‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ func convertRowsFor{{.MethodName}}(w *io.PipeWriter, {{.Arg.SlicePair}}) {
1010
{{- range $arg.CopyFromMySQLFields}}
1111
{{- if eq .Type "string"}}
1212
e.AppendString({{if eq (len $arg.CopyFromMySQLFields) 1}}row{{else}}row.{{.Name}}{{end}})
13-
{{- else if eq .Type "[]byte"}}
13+
{{- else if or (eq .Type "[]byte") (eq .Type "json.RawMessage")}}
1414
e.AppendBytes({{if eq (len $arg.CopyFromMySQLFields) 1}}row{{else}}row.{{.Name}}{{end}})
1515
{{- else}}
1616
e.AppendValue({{if eq (len $arg.CopyFromMySQLFields) 1}}row{{else}}row.{{.Name}}{{end}})

‎internal/endtoend/testdata/json/mysql/go/copyfrom.go‎

Lines changed: 51 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎internal/endtoend/testdata/json/mysql/go/query.sql.go‎

Lines changed: 10 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎internal/endtoend/testdata/json/mysql/query.sql‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,5 @@
11
-- name: SelectFoo :exec
22
SELECT * FROM foo;
3+
4+
-- name: BulkInsert :copyfrom
5+
INSERT INTO foo (a, b) VALUES (?, ?);

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
{
55
"path": "go",
66
"engine": "mysql",
7+
"sql_driver": "github.com/go-sql-driver/mysql",
78
"name": "querytest",
89
"schema": "schema.sql",
910
"queries": "query.sql"

0 commit comments

Comments
 (0)