149 lines
3.1 KiB
Go
149 lines
3.1 KiB
Go
package jet
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"errors"
|
|
"github.com/go-jet/jet/execution"
|
|
"github.com/go-jet/jet/internal/utils"
|
|
)
|
|
|
|
// UpdateStatement is interface of SQL UPDATE statement
|
|
type UpdateStatement interface {
|
|
Statement
|
|
|
|
SET(value interface{}, values ...interface{}) UpdateStatement
|
|
MODEL(data interface{}) UpdateStatement
|
|
|
|
WHERE(expression BoolExpression) UpdateStatement
|
|
RETURNING(projections ...projection) UpdateStatement
|
|
}
|
|
|
|
func newUpdateStatement(table WritableTable, columns []column) UpdateStatement {
|
|
return &updateStatementImpl{
|
|
table: table,
|
|
columns: columns,
|
|
row: make([]clause, 0, len(columns)),
|
|
}
|
|
}
|
|
|
|
type updateStatementImpl struct {
|
|
table WritableTable
|
|
columns []column
|
|
row []clause
|
|
where BoolExpression
|
|
returning []projection
|
|
}
|
|
|
|
func (u *updateStatementImpl) SET(value interface{}, values ...interface{}) UpdateStatement {
|
|
u.row = unwindRowFromValues(value, values)
|
|
|
|
return u
|
|
}
|
|
|
|
func (u *updateStatementImpl) MODEL(data interface{}) UpdateStatement {
|
|
u.row = unwindRowFromModel(u.columns, data)
|
|
|
|
return u
|
|
}
|
|
|
|
func (u *updateStatementImpl) WHERE(expression BoolExpression) UpdateStatement {
|
|
u.where = expression
|
|
return u
|
|
}
|
|
|
|
func (u *updateStatementImpl) RETURNING(projections ...projection) UpdateStatement {
|
|
u.returning = projections
|
|
return u
|
|
}
|
|
|
|
func (u *updateStatementImpl) Sql() (sql string, args []interface{}, err error) {
|
|
out := &sqlBuilder{}
|
|
|
|
out.newLine()
|
|
out.writeString("UPDATE")
|
|
|
|
if utils.IsNil(u.table) {
|
|
return "", nil, errors.New("jet: table to update is nil")
|
|
}
|
|
|
|
if err = u.table.serialize(updateStatement, out); err != nil {
|
|
return
|
|
}
|
|
|
|
if len(u.columns) == 0 {
|
|
return "", nil, errors.New("jet: no columns selected")
|
|
}
|
|
|
|
if len(u.row) == 0 {
|
|
return "", nil, errors.New("jet: no values to updated")
|
|
}
|
|
|
|
out.newLine()
|
|
out.writeString("SET")
|
|
|
|
if len(u.columns) > 1 {
|
|
out.writeString("(")
|
|
}
|
|
|
|
err = serializeColumnNames(u.columns, out)
|
|
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
if len(u.columns) > 1 {
|
|
out.writeString(")")
|
|
}
|
|
|
|
out.writeString("=")
|
|
|
|
if len(u.row) > 1 {
|
|
out.writeString("(")
|
|
}
|
|
|
|
err = serializeClauseList(updateStatement, u.row, out)
|
|
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
if len(u.row) > 1 {
|
|
out.writeString(")")
|
|
}
|
|
|
|
if u.where == nil {
|
|
return "", nil, errors.New("jet: WHERE clause not set")
|
|
}
|
|
|
|
if err = out.writeWhere(updateStatement, u.where); err != nil {
|
|
return
|
|
}
|
|
|
|
if err = out.writeReturning(updateStatement, u.returning); err != nil {
|
|
return
|
|
}
|
|
|
|
sql, args = out.finalize()
|
|
return
|
|
}
|
|
|
|
func (u *updateStatementImpl) DebugSql() (query string, err error) {
|
|
return debugSql(u)
|
|
}
|
|
|
|
func (u *updateStatementImpl) Query(db execution.DB, destination interface{}) error {
|
|
return query(u, db, destination)
|
|
}
|
|
|
|
func (u *updateStatementImpl) QueryContext(context context.Context, db execution.DB, destination interface{}) error {
|
|
return queryContext(context, u, db, destination)
|
|
}
|
|
|
|
func (u *updateStatementImpl) Exec(db execution.DB) (res sql.Result, err error) {
|
|
return exec(u, db)
|
|
}
|
|
|
|
func (u *updateStatementImpl) ExecContext(context context.Context, db execution.DB) (res sql.Result, err error) {
|
|
return execContext(context, u, db)
|
|
}
|