dbsql

package
v0.3.71 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 17, 2025 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DatabaseNotInitializedError = errors.New("database_not_initialized")
)

Functions

func BuildCountCommand

func BuildCountCommand(tableName string, filter string) string

func BuildCountDistinctCommand

func BuildCountDistinctCommand(tableName, fieldName, filter string) string

func BuildDeleteCommand

func BuildDeleteCommand(tableName string, filter string) string

func BuildInsertCommand

func BuildInsertCommand(tableName string, raw interface{}, returning string) (response string)

func BuildInsertCommands

func BuildInsertCommands(tableName string, data []interface{}) []string

func BuildInsertCommandsReturning

func BuildInsertCommandsReturning(tableName string, data []interface{}) []string

func BuildSelect

func BuildSelect(tableOrQuery string) string

func BuildUpdateCommand

func BuildUpdateCommand(tableName string, keyName string, keyValue interface{}, data map[string]interface{}) string

func BuildUpdateCommandWithTableName

func BuildUpdateCommandWithTableName(tableName string, keyName string, keyValue interface{}, data map[string]interface{}) string

func SqlResultToMap

func SqlResultToMap(result *DatabaseResult) (map[string]interface{}, error)

Types

type Database

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

func NewDatabase

func NewDatabase(driverName, connectionString string) (*Database, error)

func (*Database) Close

func (instance *Database) Close() error

func (*Database) Exec

func (instance *Database) Exec(query string, args ...interface{}) *DatabaseResult

func (*Database) Query

func (instance *Database) Query(query string, args ...interface{}) *DatabaseRows

func (*Database) QueryRow

func (instance *Database) QueryRow(query string, response interface{}, args ...interface{}) *DatabaseRow

type DatabaseResult

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

func NewDatabaseResult

func NewDatabaseResult(result sql.Result, err error) *DatabaseResult

func (*DatabaseResult) Error

func (instance *DatabaseResult) Error() string

func (*DatabaseResult) GetError

func (instance *DatabaseResult) GetError() error

func (*DatabaseResult) HasError

func (instance *DatabaseResult) HasError() bool

func (*DatabaseResult) LastInsertId

func (instance *DatabaseResult) LastInsertId() (int64, error)

func (*DatabaseResult) RowsAffected

func (instance *DatabaseResult) RowsAffected() (int64, error)

type DatabaseRow

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

func NewDatabaseRow

func NewDatabaseRow(row *sql.Row, response interface{}) *DatabaseRow

func (*DatabaseRow) Error

func (instance *DatabaseRow) Error() string

func (*DatabaseRow) GetError

func (instance *DatabaseRow) GetError() error

func (*DatabaseRow) HasError

func (instance *DatabaseRow) HasError() bool

type DatabaseRows

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

func NewDatabaseRows

func NewDatabaseRows(rows *sql.Rows, err error) *DatabaseRows

func (*DatabaseRows) All

func (instance *DatabaseRows) All() ([]map[string]interface{}, error)

func (*DatabaseRows) Close

func (instance *DatabaseRows) Close() error

func (*DatabaseRows) Columns

func (instance *DatabaseRows) Columns() ([]string, error)

func (*DatabaseRows) Error

func (instance *DatabaseRows) Error() string

func (*DatabaseRows) First

func (instance *DatabaseRows) First() (map[string]interface{}, error)

func (*DatabaseRows) ForEach

func (instance *DatabaseRows) ForEach(callback func(item map[string]interface{}) bool) error

func (*DatabaseRows) GetError

func (instance *DatabaseRows) GetError() error

func (*DatabaseRows) HasError

func (instance *DatabaseRows) HasError() bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL