0f4df23290
Some checks failed
kotlin / test (push) Has been skipped
python / test (push) Has been skipped
typescript / test (push) Has been skipped
go / build darwin/amd64 (push) Has been cancelled
go / build linux/amd64 (push) Has been cancelled
go / build windows/amd64 (push) Has been cancelled
go / build darwin/arm64 (push) Has been cancelled
go / build linux/arm64 (push) Has been cancelled
go / build windows/arm64 (push) Has been cancelled
go / test (push) Has been cancelled
go / vuln_check (push) Has been cancelled
89 lines
3.1 KiB
Go
89 lines
3.1 KiB
Go
// Code generated by sqlc. DO NOT EDIT.
|
|
// versions:
|
|
// sqlc v1.31.1
|
|
// source: copyfrom.go
|
|
|
|
package querytest
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"fmt"
|
|
"io"
|
|
"sync/atomic"
|
|
|
|
"github.com/go-sql-driver/mysql"
|
|
"github.com/hexon/mysqltsv"
|
|
)
|
|
|
|
var readerHandlerSequenceForInsertSingleValue uint32 = 1
|
|
|
|
func convertRowsForInsertSingleValue(w *io.PipeWriter, a []sql.NullString) {
|
|
e := mysqltsv.NewEncoder(w, 1, nil)
|
|
for _, row := range a {
|
|
e.AppendValue(row)
|
|
}
|
|
w.CloseWithError(e.Close())
|
|
}
|
|
|
|
// InsertSingleValue uses MySQL's LOAD DATA LOCAL INFILE and is not atomic.
|
|
//
|
|
// Errors and duplicate keys are treated as warnings and insertion will
|
|
// continue, even without an error for some cases. Use this in a transaction
|
|
// and use SHOW WARNINGS to check for any problems and roll back if you want to.
|
|
//
|
|
// Check the documentation for more information:
|
|
// https://dev.mysql.com/doc/refman/8.0/en/load-data.html#load-data-error-handling
|
|
func (q *Queries) InsertSingleValue(ctx context.Context, a []sql.NullString) (int64, error) {
|
|
pr, pw := io.Pipe()
|
|
defer pr.Close()
|
|
rh := fmt.Sprintf("InsertSingleValue_%d", atomic.AddUint32(&readerHandlerSequenceForInsertSingleValue, 1))
|
|
mysql.RegisterReaderHandler(rh, func() io.Reader { return pr })
|
|
defer mysql.DeregisterReaderHandler(rh)
|
|
go convertRowsForInsertSingleValue(pw, a)
|
|
// The string interpolation is necessary because LOAD DATA INFILE requires
|
|
// the file name to be given as a literal string.
|
|
result, err := q.db.ExecContext(ctx, fmt.Sprintf("LOAD DATA LOCAL INFILE '%s' INTO TABLE `foo` %s (a)", "Reader::"+rh, mysqltsv.Escaping))
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return result.RowsAffected()
|
|
}
|
|
|
|
var readerHandlerSequenceForInsertValues uint32 = 1
|
|
|
|
func convertRowsForInsertValues(w *io.PipeWriter, arg []InsertValuesParams) {
|
|
e := mysqltsv.NewEncoder(w, 4, nil)
|
|
for _, row := range arg {
|
|
e.AppendValue(row.A)
|
|
e.AppendValue(row.B)
|
|
e.AppendValue(row.C)
|
|
e.AppendValue(row.D)
|
|
}
|
|
w.CloseWithError(e.Close())
|
|
}
|
|
|
|
// InsertValues uses MySQL's LOAD DATA LOCAL INFILE and is not atomic.
|
|
//
|
|
// Errors and duplicate keys are treated as warnings and insertion will
|
|
// continue, even without an error for some cases. Use this in a transaction
|
|
// and use SHOW WARNINGS to check for any problems and roll back if you want to.
|
|
//
|
|
// Check the documentation for more information:
|
|
// https://dev.mysql.com/doc/refman/8.0/en/load-data.html#load-data-error-handling
|
|
func (q *Queries) InsertValues(ctx context.Context, arg []InsertValuesParams) (int64, error) {
|
|
pr, pw := io.Pipe()
|
|
defer pr.Close()
|
|
rh := fmt.Sprintf("InsertValues_%d", atomic.AddUint32(&readerHandlerSequenceForInsertValues, 1))
|
|
mysql.RegisterReaderHandler(rh, func() io.Reader { return pr })
|
|
defer mysql.DeregisterReaderHandler(rh)
|
|
go convertRowsForInsertValues(pw, arg)
|
|
// The string interpolation is necessary because LOAD DATA INFILE requires
|
|
// the file name to be given as a literal string.
|
|
result, err := q.db.ExecContext(ctx, fmt.Sprintf("LOAD DATA LOCAL INFILE '%s' INTO TABLE `foo` %s (a, b, c, d)", "Reader::"+rh, mysqltsv.Escaping))
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return result.RowsAffected()
|
|
}
|