Function NewCheckpointQueryBuilder

go/sql/builder.go:126–163

(databaseName, tableName string, uniqueKeyColumns *ColumnList)

}

func NewCheckpointQueryBuilder(databaseName, tableName string, uniqueKeyColumns *ColumnList) (*CheckpointInsertQueryBuilder, error) {
	if uniqueKeyColumns.Len() == 0 {
		return nil, fmt.Errorf("got 0 columns in BuildSetCheckpointInsertQuery")
	}
	values := buildColumnsPreparedValues(uniqueKeyColumns)
	minUniqueColNames := []string{}
	maxUniqueColNames := []string{}
	for _, name := range uniqueKeyColumns.Names() {
		minColName := TruncateColumnName(name, MaxColumnNameLength-4) + "_min"
		maxColName := TruncateColumnName(name, MaxColumnNameLength-4) + "_max"
		minUniqueColNames = append(minUniqueColNames, minColName)
		maxUniqueColNames = append(maxUniqueColNames, maxColName)
	}
	databaseName = EscapeName(databaseName)
	tableName = EscapeName(tableName)
	stmt := fmt.Sprintf(`
		insert /* gh-ost */
		into %s.%s
			(gh_ost_chk_timestamp, gh_ost_chk_coords, gh_ost_chk_iteration,
			 gh_ost_rows_copied, gh_ost_dml_applied, gh_ost_is_cutover,
  			 %s, %s)
		values
			(unix_timestamp(now()), ?, ?,
			 ?, ?, ?,
			 %s, %s)`,
		databaseName, tableName,
		strings.Join(minUniqueColNames, ", "),
		strings.Join(maxUniqueColNames, ", "),
		strings.Join(values, ", "),
		strings.Join(values, ", "),
	)

	b := &CheckpointInsertQueryBuilder{
		uniqueKeyColumns:  uniqueKeyColumns,
		preparedStatement: stmt,
	}
	return b, nil
}

// BuildQuery builds the insert query.
func (b *CheckpointInsertQueryBuilder) BuildQuery(uniqueKeyArgs []interface{}) (string, []interface{}, error) {