Added execquery implementations
This commit is contained in:
parent
2abe35e6f9
commit
6d8706c07d
1 changed files with 11 additions and 5 deletions
|
@ -79,16 +79,22 @@ func buildUpdateQuery(q *Query) (*bytes.Buffer, []interface{}) {
|
||||||
return buf, nil
|
return buf, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func ExecQuery(q *Query) error {
|
// ExecQuery executes a query that does not need a row returned
|
||||||
return nil
|
func ExecQuery(q *Query) (sql.Result, error) {
|
||||||
|
qs, args := buildQuery(q)
|
||||||
|
return q.executor.Exec(qs, args...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func ExecQueryOne(q *Query) (*sql.Row, error) {
|
// ExecQueryOne executes the query for the One finisher and returns a row
|
||||||
return nil, nil
|
func ExecQueryOne(q *Query) *sql.Row {
|
||||||
|
qs, args := buildQuery(q)
|
||||||
|
return q.executor.QueryRow(qs, args)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ExecQueryAll executes the query for the All finisher and returns multiple rows
|
||||||
func ExecQueryAll(q *Query) (*sql.Rows, error) {
|
func ExecQueryAll(q *Query) (*sql.Rows, error) {
|
||||||
return nil, nil
|
qs, args := buildQuery(q)
|
||||||
|
return q.executor.Query(qs, args)
|
||||||
}
|
}
|
||||||
|
|
||||||
func SetDelete(q *Query) {
|
func SetDelete(q *Query) {
|
||||||
|
|
Loading…
Reference in a new issue