Method transformationUpdate

provider/sql.go:1641–1649

(db *sql.DB, tableName string, query string)

}

func (q defaultOfflineSQLQueries) transformationUpdate(db *sql.DB, tableName string, query string) error {
	tempName := sanitize(fmt.Sprintf("tmp_%s", tableName))
	fullQuery := fmt.Sprintf("CREATE TABLE %s AS SELECT * FROM ( %s )", tempName, query)
	err := q.atomicUpdate(db, tableName, tempName, fullQuery)
	if err != nil {
		return err
	}
	return nil
}

func (q defaultOfflineSQLQueries) transformationExists() string {
	bind := q.newVariableBindingIterator()