jdb

package
v1.1.228 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2026 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Postgres = "postgres"
	Oracle   = "oracle"
	Mysql    = "mysql"
)
View Source 
const (
	EVENT_SQL_ERROR   = "sql:error"
	EVENT_SQL_QUERY   = "sql:query"
	EVENT_SQL_DDL     = "sql:definition"
	EVENT_SQL_COMMAND = "sql:command"
)
View Source 
const (
	KEY = "_id"
)

Variables

This section is empty.

Functions

func ChangePassword 

func ChangePassword(db *DB, name, password string) error

Changue password

func CreateColumn 

func CreateColumn(db *DB, schema, table, name, kind, defaultValue string) error

Create column

func CreateDatabase 

func CreateDatabase(db *DB, name string) error

* * Created database component *

func CreateIndex 

func CreateIndex(db *DB, schema, table, field string) error

Create index

func CreateSchema 

func CreateSchema(db *DB, name string) error

Create schema

func CreateSequence 

func CreateSequence(db *DB, schema, tag string) error

Create serie

func CreateTrigger 

func CreateTrigger(db *DB, schema, table, name, when, event, function string) error

Create trigger

func CreateUser 

func CreateUser(db *DB, name, password string) error

Create user

func DefineSeries added in v1.1.225 

func DefineSeries(db *DB) *series

* * DefineSeries * @param db *DB * @return *series *

func DropColumn 

func DropColumn(db *DB, schema, table, name string) error

Drop column

func DropDatabase 

func DropDatabase(db *DB, name string) error

Drop database

func DropIndex 

func DropIndex(db *DB, schema, table, field string) error

Drop index

func DropSchema 

func DropSchema(db *DB, name string) error

Drop schema

func DropSerie 

func DropSerie(db *DB, schema, name string) error

Drop serie

func DropTable 

func DropTable(db *DB, schema, name string) error

Drop table

func DropTrigger 

func DropTrigger(db *DB, schema, table, name string) error

Drop trigger

func DropUser 

func DropUser(db *DB, name string) error

Drop user

func ExistColum 

func ExistColum(db *DB, schema, table, name string) (bool, error)

Exist column

func ExistDatabase 

func ExistDatabase(db *DB, name string) (bool, error)

Exist database

func ExistIndex 

func ExistIndex(db *DB, schema, table, field string) (bool, error)

Exist index

func ExistSchema 

func ExistSchema(db *DB, name string) (bool, error)

Exist schema

func ExistSerie 

func ExistSerie(db *DB, schema, name string) (bool, error)

Exist serie

func ExistTable 

func ExistTable(db *DB, schema, name string) (bool, error)

Exist table

func ExistTrigger 

func ExistTrigger(db *DB, schema, table, name string) (bool, error)

Exist trigger

func ExistUser 

func ExistUser(db *DB, name string) (bool, error)

Exist user

func GetSeries added in v1.1.225 

func GetSeries(kind, tag string) (string, error)

* * GetSeries * @param kind, tag string * @return string, error *

func InitCore 

func InitCore(db *DB) error

func LastSerie 

func LastSerie(db *DB, tag string) int

* * LastSerie * @param db *DB, tag string * @return int *

func NextCode 

func NextCode(db *DB, tag, prefix string) string

* * NextCode * @param db *DB, tag string, prefix string * @return string *

func NextSerie 

func NextSerie(db *DB, tag string) int64

* * NextSerie * @param db *DB, tag string * @return int64 *

func SQLDDL 

func SQLDDL(sql string, args ...any) string

* * SQLDDL * @param sql string, args ...any * @return string *

func SQLParse 

func SQLParse(sql string, args ...any) string

* * SQLParse * @param sql string, args ...any * @return string *

func SQLQuote 

func SQLQuote(sql string) string

* * SQLQuote * @param sql string * @return string *

func SetSerie 

func SetSerie(db *DB, tag string, val int) (int, error)

* * SetSerie * @param db *DB, tag string, val int * @return int, error *

func SetSeries added in v1.1.225 

func SetSeries(kind, tag string, val int) (int, error)

* * SetSeries * @param kind, tag string, val int * @return int, error *

func TipoSQL added in v1.1.132 

func TipoSQL(query string) string

Types

type DB 

type DB struct {
	Description string
	Driver      string
	Host        string
	Port        int
	Dbname      string
	Connection  string
	UseCore     bool
	// contains filtered or unexported fields
}

func ConnectTo 

func ConnectTo(params et.Json) (*DB, error)

* * ConnectTo * @param params et.Json * @return *DB, error *

func Load 

func Load() (*DB, error)

* * Load * @return *Conn, error *

func LoadTo added in v1.1.118 

func LoadTo(dbname string) (*DB, error)

* * LoadTo * @param dbname string * @return *DB, error *

func (*DB) BeginTx added in v1.1.228 

func (d *DB) BeginTx(ctx context.Context) (*Tx, error)

* * BeginTx starts a new transaction on the DB connection. * @param ctx context.Context * @return *Tx, error *

func (*DB) Bulck added in v1.1.26 

func (d *DB) Bulck(sql string, args ...any) error

func (*DB) BulckContext added in v1.1.228 

func (d *DB) BulckContext(ctx context.Context, sql string, args ...any) error

* * BulckContext * @param ctx context.Context, sql string, args ...any * @return error *

func (*DB) Close 

func (c *DB) Close() error

* * Close * @return error *

func (*DB) Command 

func (d *DB) Command(sql string, args ...any) (et.Items, error)

func (*DB) CommandContext added in v1.1.228 

func (d *DB) CommandContext(ctx context.Context, sql string, args ...any) (et.Items, error)

* * CommandContext * @param ctx context.Context, sql string, args ...any * @return et.Items, error *

func (*DB) CommandSource added in v1.1.125 

func (d *DB) CommandSource(sourceField string, sql string, args ...any) (et.Items, error)

func (*DB) CommandSourceContext added in v1.1.228 

func (d *DB) CommandSourceContext(ctx context.Context, sourceField string, sql string, args ...any) (et.Items, error)

* * CommandSourceContext * @param ctx context.Context, sourceField string, sql string, args ...any * @return et.Items, error *

func (*DB) Ddl added in v1.1.125 

func (d *DB) Ddl(sql string, args ...any) error

func (*DB) DdlContext added in v1.1.228 

func (d *DB) DdlContext(ctx context.Context, sql string, args ...any) error

* * DdlContext * @param ctx context.Context, sql string, args ...any * @return error *

func (*DB) Describe 

func (c *DB) Describe() et.Json

* * Describe * @return et.Json *

func (*DB) HealthCheck added in v1.1.124 

func (c *DB) HealthCheck() bool

* * HealthCheck * @return bool *

func (*DB) Query 

func (d *DB) Query(sql string, args ...any) (et.Items, error)

func (*DB) QueryContext added in v1.1.228 

func (d *DB) QueryContext(ctx context.Context, sql string, args ...any) (et.Items, error)

* * QueryContext * @param ctx context.Context, sql string, args ...any * @return et.Items, error *

func (*DB) QueryOne 

func (d *DB) QueryOne(sql string, args ...any) (et.Item, error)

func (*DB) QueryOneContext added in v1.1.228 

func (d *DB) QueryOneContext(ctx context.Context, sql string, args ...any) (et.Item, error)

* * QueryOneContext * @param ctx context.Context, sql string, args ...any * @return et.Item, error *

func (*DB) QueryWithTotal added in v1.1.228 

func (d *DB) QueryWithTotal(totalField, sql string, args ...any) (et.Items, int, error)

func (*DB) QueryWithTotalContext added in v1.1.228 

func (d *DB) QueryWithTotalContext(ctx context.Context, totalField, sql string, args ...any) (et.Items, int, error)

* * QueryWithTotal runs a query that includes COUNT(*) OVER() AS <totalField>, * strips that column from each row, and returns items + total count. * @param ctx context.Context, totalField string, sql string, args ...any * @return et.Items, int, error *

func (*DB) SetListen 

func (db *DB) SetListen(channels map[string]HandlerListend)

* * SetListen * @param channels map[string]HandlerListend *

func (*DB) Source 

func (d *DB) Source(sourceField string, sql string, args ...any) (et.Items, error)

func (*DB) SourceContext added in v1.1.228 

func (d *DB) SourceContext(ctx context.Context, sourceField string, sql string, args ...any) (et.Items, error)

* * SourceContext * @param ctx context.Context, sourceField string, sql string, args ...any * @return et.Items, error *

func (*DB) SourceWithTotal added in v1.1.228 

func (d *DB) SourceWithTotal(totalField, sourceField, sql string, args ...any) (et.Items, int, error)

func (*DB) SourceWithTotalContext added in v1.1.228 

func (d *DB) SourceWithTotalContext(ctx context.Context, totalField, sourceField, sql string, args ...any) (et.Items, int, error)

* * SourceWithTotal runs a query that includes COUNT(*) OVER() AS <totalField>, * extracts the JSONB source field per row, and returns items + total count. * @param ctx context.Context, totalField string, sourceField string, sql string, args ...any * @return et.Items, int, error *

type HandlerListend 

type HandlerListend func(res et.Json)

type Tx added in v1.1.228 

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

* * Tx wraps a *sql.Tx exposing the same query methods as DB so that * linq operations can be executed inside a transaction transparently. *

func (*Tx) Command added in v1.1.228 

func (t *Tx) Command(sql string, args ...any) (et.Items, error)

* * Command executes a DML statement inside the transaction. * @param sql string, args ...any * @return et.Items, error *

func (*Tx) CommandSource added in v1.1.228 

func (t *Tx) CommandSource(sourceField, sql string, args ...any) (et.Items, error)

* * CommandSource executes a DML statement inside the transaction and * extracts the JSONB sourceField from each returned row. * @param sourceField string, sql string, args ...any * @return et.Items, error *

func (*Tx) Commit added in v1.1.228 

func (t *Tx) Commit() error

* * Commit commits the transaction. * @return error *

func (*Tx) Query added in v1.1.228 

func (t *Tx) Query(sql string, args ...any) (et.Items, error)

* * Query executes a SELECT inside the transaction. * @param sql string, args ...any * @return et.Items, error *

func (*Tx) Rollback added in v1.1.228 

func (t *Tx) Rollback() error

* * Rollback aborts the transaction. * @return error *

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.