Function NewDMLInsertQueryBuilder

go/sql/builder.go:859–892

NewDMLInsertQueryBuilder creates a new DMLInsertQueryBuilder. It prepares the INSERT query statement. Returns an error if no shared columns are given, the shared columns are not a subset of the table columns, or the prepared statement cannot be built.

(databaseName, tableName string, tableColumns, sharedColumns, mappedSharedColumns *ColumnList)

// Returns an error if no shared columns are given, the shared columns are not a subset of the table columns,
// or the prepared statement cannot be built.
func NewDMLInsertQueryBuilder(databaseName, tableName string, tableColumns, sharedColumns, mappedSharedColumns *ColumnList) (*DMLInsertQueryBuilder, error) {
	if !sharedColumns.IsSubsetOf(tableColumns) {
		return nil, fmt.Errorf("shared columns is not a subset of table columns in NewDMLInsertQueryBuilder")
	}
	if sharedColumns.Len() == 0 {
		return nil, fmt.Errorf("no shared columns found in NewDMLInsertQueryBuilder")
	}
	databaseName = EscapeName(databaseName)
	tableName = EscapeName(tableName)
	mappedSharedColumnNames := duplicateNames(mappedSharedColumns.Names())
	for i := range mappedSharedColumnNames {
		mappedSharedColumnNames[i] = EscapeName(mappedSharedColumnNames[i])
	}
	preparedValues := buildColumnsPreparedValues(mappedSharedColumns)

	stmt := fmt.Sprintf(`
		insert /* gh-ost %s.%s */ ignore
		into
			%s.%s
			(%s)
		values
			(%s)`,
		databaseName, tableName,
		databaseName, tableName,
		strings.Join(mappedSharedColumnNames, ", "),
		strings.Join(preparedValues, ", "),
	)

	return &DMLInsertQueryBuilder{
		tableColumns:      tableColumns,
		sharedColumns:     sharedColumns,
		preparedStatement: stmt,
	}, nil
}

// BuildQuery builds the arguments array for a DML event INSERT query.
// It returns the query string and the shared arguments array.