sqlxchain

sqlxchain

A thin wrapper around sqlx for command chaining, as in the following simple example:

db, _ = sqlxchain.New("mysql", dns)

var now int64
var id int64

err := db.Context().Begin().
    Get(&now, "SELECT UNIX_TIMESTAMP()").
    Get(&id, "SELECT id FROM employee WHERE is_terrible=1 LIMIT 1").
    Exec("UPDATE employee SET terminated=? WHERE id=?", now, id).
    Commit().
    Err()

The error is propagated through each call. Once an error occurs, no other action is performed. If there was an error before Commit gets called, then Commit will perform a rollback.