GOMODULES
/
goose
mirror of https://github.com/pressly/goose.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix sql

pull/131/head
1vn 2018-11-26 10:55:25 -05:00
parent 1dd31552aa
commit 66bba2f050
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dialect.go
View File

@ -64,7 +64,7 @@ func (pg PostgresDialect) insertVersionSQL() string {
}
func (pg PostgresDialect) updateVersionSQL() string {
return fmt.Sprintf("UPDATE %s SET version_id=? WHERE version_id=?;", TableName())
return fmt.Sprintf("UPDATE %s SET version_id=? WHERE version_id=$1;", TableName())
}
func (pg PostgresDialect) dbVersionQuery(db *sql.DB) (*sql.Rows, error) {
@ -77,7 +77,7 @@ func (pg PostgresDialect) dbVersionQuery(db *sql.DB) (*sql.Rows, error) {
}
func (pg PostgresDialect) deleteVersionSQL() string {
return fmt.Sprintf("DELETE FROM %s WHERE version_id=?;", TableName())
return fmt.Sprintf("DELETE FROM %s WHERE version_id=$1;", TableName())
}
////////////////////////////
@ -139,7 +139,7 @@ func (m Sqlite3Dialect) insertVersionSQL() string {
}
func (m Sqlite3Dialect) updateVersionSQL() string {
return fmt.Sprintf("UPDATE %s SET version_id=? WHERE version_id=?;", TableName())
return fmt.Sprintf("UPDATE %s SET version_id=%1 WHERE version_id=2;", TableName())
}
func (m Sqlite3Dialect) dbVersionQuery(db *sql.DB) (*sql.Rows, error) {
@ -177,7 +177,7 @@ func (rs RedshiftDialect) insertVersionSQL() string {
}
func (rs RedshiftDialect) updateVersionSQL() string {
return fmt.Sprintf("UPDATE %s SET version_id=? WHERE version_id=?;", TableName())
return fmt.Sprintf("UPDATE %s SET version_id=%1 WHERE version_id=$2;", TableName())
}
func (rs RedshiftDialect) dbVersionQuery(db *sql.DB) (*sql.Rows, error) {