db

package
v1.0.33 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2022 License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DEFAULT_QUERY_TIMEOUT = 0
	UPDATE_QUERY_TIMEOUT  = 0
	BULK_QUERY_TIMEOUT    = 0
)

Variables

View Source 
var ArrayOfIndexError arrayOfIndexError
View Source 
var EmptyResultSet = ResultSet{}
View Source 
var ParseColumnError parseColumnError
View Source 
var TimeParseColumnError timeParseColumnError
View Source 
var UnknownColumnError unknownCloumnError

Functions

This section is empty.

Types

type ColumnType 

type ColumnType struct {
	Name            string
	NullSupportable bool
	Nullable        bool
	LengthVariable  bool
	Length          int64

	PrecisionScale bool

	Precision int64
	Scale     int64

	SqlType  string
	DataType reflect.Type
}

type DBPlus added in v1.0.27 

type DBPlus struct {
	DB             *sql.DB
	QUERY_TIMEOUT  int
	UPDATE_TIMEOUT int
	BULK_TIMEOUT   int
}

func (*DBPlus) Begin added in v1.0.27 

func (d *DBPlus) Begin() (*sql.Tx, error)

func (*DBPlus) Bulk added in v1.0.27 

func (d *DBPlus) Bulk(update string, args [][]any) ([]int64, []int64, error)

func (*DBPlus) BulkWithTimeout added in v1.0.27 

func (d *DBPlus) BulkWithTimeout(update string, timeout int, args [][]any) ([]int64, []int64, error)

func (*DBPlus) BulkWithTx added in v1.0.27 

func (d *DBPlus) BulkWithTx(tx *sql.Tx, update string, args [][]any) ([]int64, []int64, error)

func (*DBPlus) Commit added in v1.0.27 

func (d *DBPlus) Commit(tx *sql.Tx) error

func (*DBPlus) Exec added in v1.0.27 

func (d *DBPlus) Exec(update string, args ...any) (int64, int64, error)

func (*DBPlus) ExecWithTimeout added in v1.0.27 

func (d *DBPlus) ExecWithTimeout(update string, timeout int, args ...any) (int64, int64, error)

func (*DBPlus) ExecWithTx added in v1.0.27 

func (d *DBPlus) ExecWithTx(tx *sql.Tx, sql string, args ...any) (int64, int64, error)

func (*DBPlus) GetDB added in v1.0.27 

func (d *DBPlus) GetDB() *sql.DB

func (*DBPlus) QueryBool added in v1.0.27 

func (d *DBPlus) QueryBool(query string, args ...any) (*bool, error)

func (*DBPlus) QueryCount added in v1.0.27 

func (d *DBPlus) QueryCount(query string, args ...any) (int64, error)

func (*DBPlus) QueryFloat added in v1.0.27 

func (d *DBPlus) QueryFloat(query string, args ...any) (*float64, error)

func (*DBPlus) QueryInt added in v1.0.27 

func (d *DBPlus) QueryInt(query string, args ...any) (*int64, error)

func (*DBPlus) QueryOne added in v1.0.28 

func (d *DBPlus) QueryOne(query string, args ...any) (map[string]string, error)

func (*DBPlus) QueryResultSet added in v1.0.27 

func (d *DBPlus) QueryResultSet(query string, args ...any) (ResultSet, error)

func (*DBPlus) QueryResultSetWithTimeout added in v1.0.27 

func (d *DBPlus) QueryResultSetWithTimeout(query string, timeout int, args ...any) (ResultSet, error)

func (*DBPlus) QueryString added in v1.0.27 

func (d *DBPlus) QueryString(query string, args ...any) (*string, error)

func (*DBPlus) QueryWithTx added in v1.0.27 

func (d *DBPlus) QueryWithTx(tx *sql.Tx, sql string, args ...any) (ResultSet, error)

func (*DBPlus) Rollback added in v1.0.27 

func (d *DBPlus) Rollback(tx *sql.Tx) error

type ResultSet 

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

func New added in v1.0.27 

func New(rows *sql.Rows) (ResultSet, error)

func (*ResultSet) Get added in v1.0.27 

func (rs *ResultSet) Get(idx int) ([]*string, error)

func (*ResultSet) GetBool added in v1.0.27 

func (rs *ResultSet) GetBool(idx, column int) (*bool, error)

func (*ResultSet) GetBoolByName added in v1.0.27 

func (rs *ResultSet) GetBoolByName(idx int, columnName string) (*bool, error)

func (*ResultSet) GetBytes added in v1.0.27 

func (rs *ResultSet) GetBytes(idx, column int) ([]byte, error)

func (*ResultSet) GetBytesByName added in v1.0.27 

func (rs *ResultSet) GetBytesByName(idx int, columnName string) ([]byte, error)

func (*ResultSet) GetFloat added in v1.0.27 

func (rs *ResultSet) GetFloat(idx int, column int) (*float64, error)

func (*ResultSet) GetFloatByName added in v1.0.27 

func (rs *ResultSet) GetFloatByName(idx int, columnName string) (*float64, error)

func (*ResultSet) GetInt added in v1.0.27 

func (rs *ResultSet) GetInt(idx int, column int) (*int64, error)

func (*ResultSet) GetIntByName added in v1.0.27 

func (rs *ResultSet) GetIntByName(idx int, columnName string) (*int64, error)

func (*ResultSet) GetMeta added in v1.0.27 

func (rs *ResultSet) GetMeta() ResultSetMetaData

func (*ResultSet) GetString added in v1.0.27 

func (rs *ResultSet) GetString(idx, column int) (*string, error)

func (*ResultSet) GetStringByName added in v1.0.27 

func (rs *ResultSet) GetStringByName(idx int, columnName string) (*string, error)

func (*ResultSet) GetStringFromRaw added in v1.0.27 

func (rs *ResultSet) GetStringFromRaw(data *string) (*string, error)

func (*ResultSet) GetTime added in v1.0.27 

func (rs *ResultSet) GetTime(idx, column int, layout string) (*time.Time, error)

func (*ResultSet) GetTimeByName added in v1.0.27 

func (rs *ResultSet) GetTimeByName(idx int, columnName string, layout string) (*time.Time, error)

func (*ResultSet) GetUint added in v1.0.27 

func (rs *ResultSet) GetUint(idx, column int) (*uint64, error)

func (*ResultSet) GetUintByName added in v1.0.27 

func (rs *ResultSet) GetUintByName(idx int, columnName string) (*uint64, error)

func (*ResultSet) Length added in v1.0.27 

func (rs *ResultSet) Length() int

type ResultSetMetaData 

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

func (ResultSetMetaData) GetColumnCount 

func (m ResultSetMetaData) GetColumnCount() int

func (ResultSetMetaData) GetColumnDataType 

func (m ResultSetMetaData) GetColumnDataType(idx int) reflect.Type

func (ResultSetMetaData) GetColumnLength 

func (m ResultSetMetaData) GetColumnLength(idx int) int64

func (ResultSetMetaData) GetColumnName 

func (m ResultSetMetaData) GetColumnName(idx int) string

func (ResultSetMetaData) GetColumnSQLType 

func (m ResultSetMetaData) GetColumnSQLType(idx int) string

func (ResultSetMetaData) GetColumnType 

func (m ResultSetMetaData) GetColumnType(idx int) ColumnType

func (ResultSetMetaData) GetColumnTypes 

func (m ResultSetMetaData) GetColumnTypes() []ColumnType

func (ResultSetMetaData) GetColumns 

func (m ResultSetMetaData) GetColumns() []string

func (ResultSetMetaData) GetPrecision 

func (m ResultSetMetaData) GetPrecision(idx int) int64

func (ResultSetMetaData) GetScale 

func (m ResultSetMetaData) GetScale(idx int) int64

func (ResultSetMetaData) IsNullable 

func (m ResultSetMetaData) IsNullable(idx int) bool

func (ResultSetMetaData) IsVariableLength 

func (m ResultSetMetaData) IsVariableLength(idx int) bool

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.