feat(plugin): Use gRPC interface for codegen plugin communication (sqlc-dev#2930)

andrewmbenton · web-flow · commit 4507ede83fb9 · 2023-11-01T16:01:33.000-07:00
* feat(plugin): Use gRPC interface for codegen plugin communication

* rename proto rpc service and messages

* make invoke methods more generic

* remove vtproto and add regular grpc buf plugin
diff --git a/buf.gen.yaml b/buf.gen.yaml
@@ -5,6 +5,6 @@ plugins:
   - plugin: buf.build/protocolbuffers/go:v1.30.0
     out: internal
     opt: paths=source_relative
-  - plugin: buf.build/community/planetscale-vtprotobuf:v0.4.0
+  - plugin: buf.build/grpc/go:v1.3.0
     out: internal
     opt: paths=source_relative
diff --git a/cmd/sqlc-gen-json/main.go b/cmd/sqlc-gen-json/main.go
@@ -9,6 +9,7 @@ import (
 
 	"github.com/sqlc-dev/sqlc/internal/codegen/json"
 	"github.com/sqlc-dev/sqlc/internal/plugin"
+	"google.golang.org/protobuf/proto"
 )
 
 func main() {
@@ -19,19 +20,19 @@ func main() {
 }
 
 func run() error {
-	var req plugin.CodeGenRequest
+	var req plugin.GenerateRequest
 	reqBlob, err := io.ReadAll(os.Stdin)
 	if err != nil {
 		return err
 	}
-	if err := req.UnmarshalVT(reqBlob); err != nil {
+	if err := proto.Unmarshal(reqBlob, &req); err != nil {
 		return err
 	}
 	resp, err := json.Generate(context.Background(), &req)
 	if err != nil {
 		return err
 	}
-	respBlob, err := resp.MarshalVT()
+	respBlob, err := proto.Marshal(resp)
 	if err != nil {
 		return err
 	}
diff --git a/internal/cmd/generate.go b/internal/cmd/generate.go
@@ -14,6 +14,7 @@ import (
 	"sync"
 
 	"golang.org/x/sync/errgroup"
+	"google.golang.org/grpc"
 	"google.golang.org/grpc/status"
 
 	"github.com/sqlc-dev/sqlc/internal/codegen/golang"
@@ -380,10 +381,10 @@ func parse(ctx context.Context, name, dir string, sql config.SQL, combo config.C
 	return c.Result(), false
 }
 
-func codegen(ctx context.Context, combo config.CombinedSettings, sql outPair, result *compiler.Result) (string, *plugin.CodeGenResponse, error) {
+func codegen(ctx context.Context, combo config.CombinedSettings, sql outPair, result *compiler.Result) (string, *plugin.GenerateResponse, error) {
 	defer trace.StartRegion(ctx, "codegen").End()
 	req := codeGenRequest(result, combo)
-	var handler ext.Handler
+	var handler grpc.ClientConnInterface
 	var out string
 	switch {
 	case sql.Plugin != nil:
@@ -453,6 +454,7 @@ func codegen(ctx context.Context, combo config.CombinedSettings, sql outPair, re
 	default:
 		return "", nil, fmt.Errorf("missing language backend")
 	}
-	resp, err := handler.Generate(ctx, req)
+	client := plugin.NewCodegenServiceClient(handler)
+	resp, err := client.Generate(ctx, req)
 	return out, resp, err
 }
diff --git a/internal/cmd/shim.go b/internal/cmd/shim.go
@@ -223,8 +223,8 @@ func pluginQueryParam(p compiler.Parameter) *plugin.Parameter {
 	}
 }
 
-func codeGenRequest(r *compiler.Result, settings config.CombinedSettings) *plugin.CodeGenRequest {
-	return &plugin.CodeGenRequest{
+func codeGenRequest(r *compiler.Result, settings config.CombinedSettings) *plugin.GenerateRequest {
+	return &plugin.GenerateRequest{
 		Settings:    pluginSettings(r, settings),
 		Catalog:     pluginCatalog(r.Catalog),
 		Queries:     pluginQueries(r),
diff --git a/internal/cmd/vet.go b/internal/cmd/vet.go
@@ -629,7 +629,7 @@ func (c *checker) checkSQL(ctx context.Context, s config.SQL) error {
 	return nil
 }
 
-func vetConfig(req *plugin.CodeGenRequest) *vet.Config {
+func vetConfig(req *plugin.GenerateRequest) *vet.Config {
 	return &vet.Config{
 		Version: req.Settings.Version,
 		Engine:  req.Settings.Engine,
diff --git a/internal/codegen/golang/gen.go b/internal/codegen/golang/gen.go
@@ -103,7 +103,7 @@ func (t *tmplCtx) codegenQueryRetval(q Query) (string, error) {
 	}
 }
 
-func Generate(ctx context.Context, req *plugin.CodeGenRequest) (*plugin.CodeGenResponse, error) {
+func Generate(ctx context.Context, req *plugin.GenerateRequest) (*plugin.GenerateResponse, error) {
 	options, err := opts.Parse(req)
 	if err != nil {
 		return nil, err
@@ -127,7 +127,7 @@ func Generate(ctx context.Context, req *plugin.CodeGenRequest) (*plugin.CodeGenR
 	return generate(req, options, enums, structs, queries)
 }
 
-func generate(req *plugin.CodeGenRequest, options *opts.Options, enums []Enum, structs []Struct, queries []Query) (*plugin.CodeGenResponse, error) {
+func generate(req *plugin.GenerateRequest, options *opts.Options, enums []Enum, structs []Struct, queries []Query) (*plugin.GenerateResponse, error) {
 	i := &importer{
 		Options: options,
 		Queries: queries,
@@ -282,7 +282,7 @@ func generate(req *plugin.CodeGenRequest, options *opts.Options, enums []Enum, s
 			return nil, err
 		}
 	}
-	resp := plugin.CodeGenResponse{}
+	resp := plugin.GenerateResponse{}
 
 	for filename, code := range output {
 		resp.Files = append(resp.Files, &plugin.File{
diff --git a/internal/codegen/golang/go_type.go b/internal/codegen/golang/go_type.go
@@ -8,7 +8,7 @@ import (
 	"github.com/sqlc-dev/sqlc/internal/plugin"
 )
 
-func addExtraGoStructTags(tags map[string]string, req *plugin.CodeGenRequest, options *opts.Options, col *plugin.Column) {
+func addExtraGoStructTags(tags map[string]string, req *plugin.GenerateRequest, options *opts.Options, col *plugin.Column) {
 	for _, override := range options.Overrides {
 		oride := override.ShimOverride
 		if oride.GoType.StructTags == nil {
@@ -33,7 +33,7 @@ func addExtraGoStructTags(tags map[string]string, req *plugin.CodeGenRequest, op
 	}
 }
 
-func goType(req *plugin.CodeGenRequest, options *opts.Options, col *plugin.Column) string {
+func goType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.Column) string {
 	// Check if the column's type has been overridden
 	for _, override := range options.Overrides {
 		oride := override.ShimOverride
@@ -63,7 +63,7 @@ func goType(req *plugin.CodeGenRequest, options *opts.Options, col *plugin.Colum
 	return typ
 }
 
-func goInnerType(req *plugin.CodeGenRequest, options *opts.Options, col *plugin.Column) string {
+func goInnerType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.Column) string {
 	columnType := sdk.DataType(col.Type)
 	notNull := col.NotNull || col.IsArray
 
diff --git a/internal/codegen/golang/mysql_type.go b/internal/codegen/golang/mysql_type.go
@@ -9,7 +9,7 @@ import (
 	"github.com/sqlc-dev/sqlc/internal/plugin"
 )
 
-func mysqlType(req *plugin.CodeGenRequest, options *opts.Options, col *plugin.Column) string {
+func mysqlType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.Column) string {
 	columnType := sdk.DataType(col.Type)
 	notNull := col.NotNull || col.IsArray
 	unsigned := col.Unsigned
diff --git a/internal/codegen/golang/opts/options.go b/internal/codegen/golang/opts/options.go
@@ -47,7 +47,7 @@ type GlobalOptions struct {
 	Rename    map[string]string `json:"rename,omitempty" yaml:"rename"`
 }
 
-func Parse(req *plugin.CodeGenRequest) (*Options, error) {
+func Parse(req *plugin.GenerateRequest) (*Options, error) {
 	options, err := parseOpts(req)
 	if err != nil {
 		return nil, err
@@ -68,7 +68,7 @@ func Parse(req *plugin.CodeGenRequest) (*Options, error) {
 	return options, nil
 }
 
-func parseOpts(req *plugin.CodeGenRequest) (*Options, error) {
+func parseOpts(req *plugin.GenerateRequest) (*Options, error) {
 	var options Options
 	if len(req.PluginOptions) == 0 {
 		return &options, nil
@@ -91,7 +91,7 @@ func parseOpts(req *plugin.CodeGenRequest) (*Options, error) {
 	return &options, nil
 }
 
-func parseGlobalOpts(req *plugin.CodeGenRequest) (*GlobalOptions, error) {
+func parseGlobalOpts(req *plugin.GenerateRequest) (*GlobalOptions, error) {
 	var options GlobalOptions
 	if len(req.GlobalOptions) == 0 {
 		return &options, nil
diff --git a/internal/codegen/golang/opts/override.go b/internal/codegen/golang/opts/override.go
@@ -76,7 +76,7 @@ func (o *Override) Matches(n *plugin.Identifier, defaultSchema string) bool {
 	return true
 }
 
-func (o *Override) parse(req *plugin.CodeGenRequest) (err error) {
+func (o *Override) parse(req *plugin.GenerateRequest) (err error) {
 	// validate deprecated postgres_type field
 	if o.Deprecated_PostgresType != "" {
 		fmt.Fprintf(os.Stderr, "WARNING: \"postgres_type\" is deprecated. Instead, use \"db_type\" to specify a type override.\n")
diff --git a/internal/codegen/golang/opts/shim.go b/internal/codegen/golang/opts/shim.go
@@ -21,7 +21,7 @@ type ShimOverride struct {
 	GoType     *ShimGoType
 }
 
-func shimOverride(req *plugin.CodeGenRequest, o *Override) *ShimOverride {
+func shimOverride(req *plugin.GenerateRequest, o *Override) *ShimOverride {
 	var column string
 	var table plugin.Identifier
 
diff --git a/internal/codegen/golang/postgresql_type.go b/internal/codegen/golang/postgresql_type.go
@@ -34,7 +34,7 @@ func parseIdentifierString(name string) (*plugin.Identifier, error) {
 	}
 }
 
-func postgresType(req *plugin.CodeGenRequest, options *opts.Options, col *plugin.Column) string {
+func postgresType(req *plugin.GenerateRequest, options *opts.Options, col *plugin.Column) string {
 	columnType := sdk.DataType(col.Type)
 	notNull := col.NotNull || col.IsArray
 	driver := parseDriver(options.SqlPackage)
diff --git a/internal/codegen/golang/result.go b/internal/codegen/golang/result.go
@@ -12,7 +12,7 @@ import (
 	"github.com/sqlc-dev/sqlc/internal/plugin"
 )
 
-func buildEnums(req *plugin.CodeGenRequest, options *opts.Options) []Enum {
+func buildEnums(req *plugin.GenerateRequest, options *opts.Options) []Enum {
 	var enums []Enum
 	for _, schema := range req.Catalog.Schemas {
 		if schema.Name == "pg_catalog" || schema.Name == "information_schema" {
@@ -59,7 +59,7 @@ func buildEnums(req *plugin.CodeGenRequest, options *opts.Options) []Enum {
 	return enums
 }
 
-func buildStructs(req *plugin.CodeGenRequest, options *opts.Options) []Struct {
+func buildStructs(req *plugin.GenerateRequest, options *opts.Options) []Struct {
 	var structs []Struct
 	for _, schema := range req.Catalog.Schemas {
 		if schema.Name == "pg_catalog" || schema.Name == "information_schema" {
@@ -182,7 +182,7 @@ func argName(name string) string {
 	return out
 }
 
-func buildQueries(req *plugin.CodeGenRequest, options *opts.Options, structs []Struct) ([]Query, error) {
+func buildQueries(req *plugin.GenerateRequest, options *opts.Options, structs []Struct) ([]Query, error) {
 	qs := make([]Query, 0, len(req.Queries))
 	for _, query := range req.Queries {
 		if query.Name == "" {
@@ -332,7 +332,7 @@ func putOutColumns(query *plugin.Query) bool {
 // JSON tags: count, count_2, count_2
 //
 // This is unlikely to happen, so don't fix it yet
-func columnsToStruct(req *plugin.CodeGenRequest, options *opts.Options, name string, columns []goColumn, useID bool) (*Struct, error) {
+func columnsToStruct(req *plugin.GenerateRequest, options *opts.Options, name string, columns []goColumn, useID bool) (*Struct, error) {
 	gs := Struct{
 		Name: name,
 	}
diff --git a/internal/codegen/golang/sqlite_type.go b/internal/codegen/golang/sqlite_type.go
@@ -9,7 +9,7 @@ import (
 	"github.com/sqlc-dev/sqlc/internal/plugin"
 )
 
-func sqliteType(req *plugin.CodeGenRequest, col *plugin.Column) string {
+func sqliteType(req *plugin.GenerateRequest, col *plugin.Column) string {
 	dt := strings.ToLower(sdk.DataType(col.Type))
 	notNull := col.NotNull || col.IsArray
 
diff --git a/internal/codegen/json/gen.go b/internal/codegen/json/gen.go
@@ -11,7 +11,7 @@ import (
 	"github.com/sqlc-dev/sqlc/internal/plugin"
 )
 
-func parseOptions(req *plugin.CodeGenRequest) (*opts, error) {
+func parseOptions(req *plugin.GenerateRequest) (*opts, error) {
 	if len(req.PluginOptions) == 0 {
 		return new(opts), nil
 	}
@@ -25,7 +25,7 @@ func parseOptions(req *plugin.CodeGenRequest) (*opts, error) {
 	return options, nil
 }
 
-func Generate(ctx context.Context, req *plugin.CodeGenRequest) (*plugin.CodeGenResponse, error) {
+func Generate(ctx context.Context, req *plugin.GenerateRequest) (*plugin.GenerateResponse, error) {
 	options, err := parseOptions(req)
 	if err != nil {
 		return nil, err
@@ -57,7 +57,7 @@ func Generate(ctx context.Context, req *plugin.CodeGenRequest) (*plugin.CodeGenR
 	if err != nil {
 		return nil, err
 	}
-	return &plugin.CodeGenResponse{
+	return &plugin.GenerateResponse{
 		Files: []*plugin.File{
 			{
 				Name:     filename,
diff --git a/internal/ext/handler.go b/internal/ext/handler.go
@@ -2,22 +2,51 @@ package ext
 
 import (
 	"context"
+	"fmt"
+
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
 
 	"github.com/sqlc-dev/sqlc/internal/plugin"
 )
 
 type Handler interface {
-	Generate(context.Context, *plugin.CodeGenRequest) (*plugin.CodeGenResponse, error)
+	Generate(context.Context, *plugin.GenerateRequest) (*plugin.GenerateResponse, error)
+
+	Invoke(ctx context.Context, method string, args any, reply any, opts ...grpc.CallOption) error
+	NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
 }
 
 type wrapper struct {
-	fn func(context.Context, *plugin.CodeGenRequest) (*plugin.CodeGenResponse, error)
+	fn func(context.Context, *plugin.GenerateRequest) (*plugin.GenerateResponse, error)
 }
 
-func (w *wrapper) Generate(ctx context.Context, req *plugin.CodeGenRequest) (*plugin.CodeGenResponse, error) {
+func (w *wrapper) Generate(ctx context.Context, req *plugin.GenerateRequest) (*plugin.GenerateResponse, error) {
 	return w.fn(ctx, req)
 }
 
-func HandleFunc(fn func(context.Context, *plugin.CodeGenRequest) (*plugin.CodeGenResponse, error)) Handler {
+func (w *wrapper) Invoke(ctx context.Context, method string, args any, reply any, opts ...grpc.CallOption) error {
+	req, ok := args.(*plugin.GenerateRequest)
+	if !ok {
+		return fmt.Errorf("args isn't a GenerateRequest")
+	}
+	resp, ok := reply.(*plugin.GenerateResponse)
+	if !ok {
+		return fmt.Errorf("reply isn't a GenerateResponse")
+	}
+	res, err := w.Generate(ctx, req)
+	if err != nil {
+		return err
+	}
+	resp.Files = res.Files
+	return nil
+}
+
+func (w *wrapper) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error) {
+	return nil, status.Error(codes.Unimplemented, "")
+}
+
+func HandleFunc(fn func(context.Context, *plugin.GenerateRequest) (*plugin.GenerateResponse, error)) Handler {
 	return &wrapper{fn}
 }
diff --git a/internal/ext/process/gen.go b/internal/ext/process/gen.go
diff --git a/internal/ext/wasm/nowasm.go b/internal/ext/wasm/nowasm.go
diff --git a/internal/ext/wasm/wasm.go b/internal/ext/wasm/wasm.go
diff --git a/internal/plugin/codegen.pb.go b/internal/plugin/codegen.pb.go
diff --git a/internal/plugin/codegen_grpc.pb.go b/internal/plugin/codegen_grpc.pb.go
diff --git a/internal/plugin/codegen_vtproto.pb.go b/internal/plugin/codegen_vtproto.pb.go
diff --git a/protos/plugin/codegen.proto b/protos/plugin/codegen.proto

Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@ import (`
`9`	`9`
`10`	`10`	`"github.com/sqlc-dev/sqlc/internal/codegen/json"`
`11`	`11`	`"github.com/sqlc-dev/sqlc/internal/plugin"`
	`12`	`+ "google.golang.org/protobuf/proto"`
`12`	`13`	`)`
`13`	`14`
`14`	`15`	`func main() {`
`@@ -19,19 +20,19 @@ func main() {`
`19`	`20`	`}`
`20`	`21`
`21`	`22`	`func run() error {`
`22`		`- var req plugin.CodeGenRequest`
	`23`	`+ var req plugin.GenerateRequest`
`23`	`24`	`reqBlob, err := io.ReadAll(os.Stdin)`
`24`	`25`	`if err != nil {`
`25`	`26`	`return err`
`26`	`27`	`}`
`27`		`- if err := req.UnmarshalVT(reqBlob); err != nil {`
	`28`	`+ if err := proto.Unmarshal(reqBlob, &req); err != nil {`
`28`	`29`	`return err`
`29`	`30`	`}`
`30`	`31`	`resp, err := json.Generate(context.Background(), &req)`
`31`	`32`	`if err != nil {`
`32`	`33`	`return err`
`33`	`34`	`}`
`34`		`- respBlob, err := resp.MarshalVT()`
	`35`	`+ respBlob, err := proto.Marshal(resp)`
`35`	`36`	`if err != nil {`
`36`	`37`	`return err`
`37`	`38`	`}`
Original file line number	Diff line number	Diff line change
`@@ -223,8 +223,8 @@ func pluginQueryParam(p compiler.Parameter) *plugin.Parameter {`
`223`	`223`	`}`
`224`	`224`	`}`
`225`	`225`
`226`		`-func codeGenRequest(r compiler.Result, settings config.CombinedSettings) plugin.CodeGenRequest {`
`227`		`- return &plugin.CodeGenRequest{`
	`226`	`+func codeGenRequest(r compiler.Result, settings config.CombinedSettings) plugin.GenerateRequest {`
	`227`	`+ return &plugin.GenerateRequest{`
`228`	`228`	`Settings: pluginSettings(r, settings),`
`229`	`229`	`Catalog: pluginCatalog(r.Catalog),`
`230`	`230`	`Queries: pluginQueries(r),`
Original file line number	Diff line number	Diff line change
`@@ -629,7 +629,7 @@ func (c *checker) checkSQL(ctx context.Context, s config.SQL) error {`
`629`	`629`	`return nil`
`630`	`630`	`}`
`631`	`631`
`632`		`-func vetConfig(req plugin.CodeGenRequest) vet.Config {`
	`632`	`+func vetConfig(req plugin.GenerateRequest) vet.Config {`
`633`	`633`	`return &vet.Config{`
`634`	`634`	`Version: req.Settings.Version,`
`635`	`635`	`Engine: req.Settings.Engine,`
Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,7 @@ func (t *tmplCtx) codegenQueryRetval(q Query) (string, error) {`
`103`	`103`	`}`
`104`	`104`	`}`
`105`	`105`
`106`		`-func Generate(ctx context.Context, req plugin.CodeGenRequest) (plugin.CodeGenResponse, error) {`
	`106`	`+func Generate(ctx context.Context, req plugin.GenerateRequest) (plugin.GenerateResponse, error) {`
`107`	`107`	`options, err := opts.Parse(req)`
`108`	`108`	`if err != nil {`
`109`	`109`	`return nil, err`
`@@ -127,7 +127,7 @@ func Generate(ctx context.Context, req plugin.CodeGenRequest) (plugin.CodeGenR`
`127`	`127`	`return generate(req, options, enums, structs, queries)`
`128`	`128`	`}`
`129`	`129`
`130`		`-func generate(req plugin.CodeGenRequest, options opts.Options, enums []Enum, structs []Struct, queries []Query) (*plugin.CodeGenResponse, error) {`
	`130`	`+func generate(req plugin.GenerateRequest, options opts.Options, enums []Enum, structs []Struct, queries []Query) (*plugin.GenerateResponse, error) {`
`131`	`131`	`i := &importer{`
`132`	`132`	`Options: options,`
`133`	`133`	`Queries: queries,`
`@@ -282,7 +282,7 @@ func generate(req plugin.CodeGenRequest, options opts.Options, enums []Enum, s`
`282`	`282`	`return nil, err`
`283`	`283`	`}`
`284`	`284`	`}`
`285`		`- resp := plugin.CodeGenResponse{}`
	`285`	`+ resp := plugin.GenerateResponse{}`
`286`	`286`
`287`	`287`	`for filename, code := range output {`
`288`	`288`	`resp.Files = append(resp.Files, &plugin.File{`
Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@ import (`
`8`	`8`	`"github.com/sqlc-dev/sqlc/internal/plugin"`
`9`	`9`	`)`
`10`	`10`
`11`		`-func addExtraGoStructTags(tags map[string]string, req plugin.CodeGenRequest, options opts.Options, col *plugin.Column) {`
	`11`	`+func addExtraGoStructTags(tags map[string]string, req plugin.GenerateRequest, options opts.Options, col *plugin.Column) {`
`12`	`12`	`for _, override := range options.Overrides {`
`13`	`13`	`oride := override.ShimOverride`
`14`	`14`	`if oride.GoType.StructTags == nil {`
`@@ -33,7 +33,7 @@ func addExtraGoStructTags(tags map[string]string, req *plugin.CodeGenRequest, op`
`33`	`33`	`}`
`34`	`34`	`}`
`35`	`35`
`36`		`-func goType(req plugin.CodeGenRequest, options opts.Options, col *plugin.Column) string {`
	`36`	`+func goType(req plugin.GenerateRequest, options opts.Options, col *plugin.Column) string {`
`37`	`37`	`// Check if the column's type has been overridden`
`38`	`38`	`for _, override := range options.Overrides {`
`39`	`39`	`oride := override.ShimOverride`
`@@ -63,7 +63,7 @@ func goType(req plugin.CodeGenRequest, options opts.Options, col *plugin.Colum`
`63`	`63`	`return typ`
`64`	`64`	`}`
`65`	`65`
`66`		`-func goInnerType(req plugin.CodeGenRequest, options opts.Options, col *plugin.Column) string {`
	`66`	`+func goInnerType(req plugin.GenerateRequest, options opts.Options, col *plugin.Column) string {`
`67`	`67`	`columnType := sdk.DataType(col.Type)`
`68`	`68`	`notNull := col.NotNull \|\| col.IsArray`
`69`	`69`
Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,7 @@ import (`
`9`	`9`	`"github.com/sqlc-dev/sqlc/internal/plugin"`
`10`	`10`	`)`
`11`	`11`
`12`		`-func mysqlType(req plugin.CodeGenRequest, options opts.Options, col *plugin.Column) string {`
	`12`	`+func mysqlType(req plugin.GenerateRequest, options opts.Options, col *plugin.Column) string {`
`13`	`13`	`columnType := sdk.DataType(col.Type)`
`14`	`14`	`notNull := col.NotNull \|\| col.IsArray`
`15`	`15`	`unsigned := col.Unsigned`
Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ func (o Override) Matches(n plugin.Identifier, defaultSchema string) bool {`
`76`	`76`	`return true`
`77`	`77`	`}`
`78`	`78`
`79`		`-func (o Override) parse(req plugin.CodeGenRequest) (err error) {`
	`79`	`+func (o Override) parse(req plugin.GenerateRequest) (err error) {`
`80`	`80`	`// validate deprecated postgres_type field`
`81`	`81`	`if o.Deprecated_PostgresType != "" {`
`82`	`82`	`fmt.Fprintf(os.Stderr, "WARNING: \"postgres_type\" is deprecated. Instead, use \"db_type\" to specify a type override.\n")`