db

type DB interface {
	// Query will execute an SQL query returning a result object. If the context
	// is a transaction then this will be used to run the query.
	Query(context.Context, SQL) *Result
	// Exec will execute an SQL query returning a result object. If the context
	// is a transaction then this will be used to run the query.
	Exec(context.Context, SQL) *Result
	// Close will close the underlying DB connection.
	Close() error
	// Begin will create a new transaction. If the passed in context is a TX
	// then a savepoint will be used. If the passed in context is cancellable it
	// will monitor this context and rollback.
	Begin(context.Context) (TX, error)
	// TX provides a safe way to execute a transaction. It ensures that if an
	// error is raised Rollback() is called and if no error is raised Commit()
	// is called.
	TX(ctx context.Context, fn func(ctx context.Context) error) error
	// Select returns a SelectStmt for the dialect.
	Select(cols ...string) SelectStmt
	// Insert returns an InsertStmt for the dialect.
	Insert() InsertStmt
	// Update returns an UpdateStmt for the dialect.
	Update(string) UpdateStmt
	// Delete returns a DeleteStmt for the dialect.
	Delete() DeleteStmt
}

type DeleteStmt struct {
	// contains filtered or unexported fields
}

type Dialect int

type InsertStmt struct {
	// contains filtered or unexported fields
}

type Option func(db *db)

type Result struct {
	*sql.Rows
	LastID       int64
	RowsAffected int64
	// contains filtered or unexported fields
}

type SQL interface {
	SQL() (string, []interface{}, error)
}

type SelectStmt struct {
	// contains filtered or unexported fields
}

type TX interface {
	context.Context

	// Rollback will rollback the current transaction. If this is a savepoint
	// then the savepoint will be rolled back. If Rollback or Commit has already
	// been called then Rollback will take no action and return no error. If the
	// context is already closed then Rollback will return.
	Rollback() error
	// Commit will commit the current transaction. If this is a savepoint then
	// the savepoint will be released.
	Commit() error
	// WithContext will copy the transaction using a new context as the base.
	// This can be used to set a new context with a cancel or deadline.
	WithContext(ctx context.Context) TX
}

type UpdateStmt struct {
	// contains filtered or unexported fields
}