dbutil

Documentation

Index

• Constants
• func BuildConditions(equal map[string]interface{}, in map[string]interface{}) ([]string, []interface{}, error)
• func BuildFeatureDataTableSchema(tableName string, entity *types.Entity, features types.FeatureList) string
• func InsertRecordsToTable(db *sqlx.DB, ctx context.Context, tableName string, records []interface{}, ...) error
• func InsertRecordsToTableTx(tx *sqlx.Tx, ctx context.Context, tableName string, records []interface{}, ...) error
• func Quote(quote string, fields ...string) string
• func TempTable(prefix string) string
• func WithTransaction(db *sqlx.DB, ctx context.Context, fn TxFn) (err error)
• type RowMap
• type TxFn

Constants

const CREATE_DATA_TABLE = `CREATE TABLE "{{TABLE_NAME}}" (
	"{{ENTITY_NAME}}" VARCHAR({{ENTITY_LENGTH}}) PRIMARY KEY,
	{{COLUMN_DEFS}});
`

Functions

func BuildConditions

func BuildConditions(equal map[string]interface{}, in map[string]interface{}) ([]string, []interface{}, error)

func BuildFeatureDataTableSchema

func BuildFeatureDataTableSchema(tableName string, entity *types.Entity, features types.FeatureList) string

func InsertRecordsToTable

func InsertRecordsToTable(db *sqlx.DB, ctx context.Context, tableName string, records []interface{}, columns []string) error

func InsertRecordsToTableTx

func InsertRecordsToTableTx(tx *sqlx.Tx, ctx context.Context, tableName string, records []interface{}, columns []string) error

func Quote

func Quote(quote string, fields ...string) string

func TempTable

func TempTable(prefix string) string

func WithTransaction

func WithTransaction(db *sqlx.DB, ctx context.Context, fn TxFn) (err error)

Types

type RowMap

type RowMap = map[string]interface{}

type TxFn

type TxFn func(ctx context.Context, tx *sqlx.Tx) error

A Txfn is a function that will be called with an initialized `Transaction` object that can be used for executing statements and queries against a database.