sql

package

v0.11.9 Latest Latest Go to latest Published: Jan 4, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Builder struct{}

Builder sql query builder

var DefaultBuilder Builder

func (b *Builder) Delete(tableName string, where map[string]interface{}) (string, []interface{}, error)

func (b *Builder) Insert(tableName string, columns []string, data ...[]interface{}) (string, []interface{}, error)

func (b *Builder) Query(tableName string, params map[string]interface{}) (string, []interface{}, error)

func (b *Builder) Update(tableName string, data, where map[string]interface{}) (string, []interface{}, error)

func (b *Builder) Where(where map[string]interface{}) (string, []interface{})

type Executor struct {
	Log *utils.CombinedLogger

	Debug bool
	// contains filtered or unexported fields
}

Executor Database Driver

func (exec *Executor) Close()

Close

func (exec *Executor) Connect(execName, dns string) (bool, error)

Connect db

@params execName, including mysql, sqlite3 @params dns, format：user:password@tpc(host:port)/databaseName?options

func (exec *Executor) Execute(sql string, args ...interface{}) (int64, int64)

Execute sql, including insert, delete and update @return (int64 number of row affected，int64 the latest record id)

func (exec *Executor) GetDB() *sql.DB

GetDB

func (exec *Executor) IsCacheEngineOK() bool

IsCacheEngineOK

func (exec *Executor) Query(sql string, args ...interface{}) *sql.Rows

Query @params sql @params arg

func (exec *Executor) QueryCache(cacheOpt map[string]interface{}, sql string, args ...interface{}) ([]map[string]interface{}, error)

QueryCache @params cacheOpt @params sql @params arg

func (exec *Executor) SetCacheEngine(cache cache.Cache)

SetCacheEngine