Method buildServerSideLoadData

backend/loaddata.go:103–113

In the non-local case, we can directly use the file path to read the data.

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

// In the non-local case, we can directly use the file path to read the data.
func (db *DuckBuilder) buildServerSideLoadData(ctx *sql.Context, insert *plan.InsertInto, dst sql.InsertableTable, load *plan.LoadData) (sql.RowIter, error) {
	_, secureFileDir, ok := sql.SystemVariables.GetGlobal("secure_file_priv")
	if !ok {
		return nil, fmt.Errorf("error: secure_file_priv variable was not found")
	}

	if err := isUnderSecureFileDir(secureFileDir, load.File); err != nil {
		return nil, sql.ErrLoadDataCannotOpen.New(err.Error())
	}
	return db.executeLoadData(ctx, insert, dst, load, load.File)
}

func (db *DuckBuilder) executeLoadData(ctx *sql.Context, insert *plan.InsertInto, dst sql.InsertableTable, load *plan.LoadData, filePath string) (sql.RowIter, error) {
	// Build the DuckDB INSERT INTO statement.