Method buildLoadData

backend/loaddata.go:58–63

buildLoadData translates a MySQL LOAD DATA statement into a DuckDB INSERT INTO statement and executes it.

(ctx *sql.Context, root sql.Node, insert *plan.InsertInto, dst sql.InsertableTable, load *plan.LoadData)

// buildLoadData translates a MySQL LOAD DATA statement
// into a DuckDB INSERT INTO statement and executes it.
func (db *DuckBuilder) buildLoadData(ctx *sql.Context, root sql.Node, insert *plan.InsertInto, dst sql.InsertableTable, load *plan.LoadData) (sql.RowIter, error) {
	if load.Local {
		return db.buildClientSideLoadData(ctx, insert, dst, load)
	}
	return db.buildServerSideLoadData(ctx, insert, dst, load)
}

// Since the data is sent to the server in the form of a byte stream,
// we use a Unix pipe to stream the data to DuckDB.