Documentation
¶
Index ¶
- func ReplaceConnection(db string, conn *sql.DB)
- type ConnectionPoolItem
- func (connectionItem *ConnectionPoolItem) BeginTransaction() (TransactionStruct, error)
- func (connectionItem *ConnectionPoolItem) Close() error
- func (connectionItem *ConnectionPoolItem) FetchList(query string, args ...interface{}) ([]string, error)
- func (connectionItem *ConnectionPoolItem) FetchQuery(query string, args ...interface{}) (map[string]string, error)
- func (connectionItem *ConnectionPoolItem) GetAll(query string, args ...interface{}) (map[int]map[string]string, error)
- func (connectionItem *ConnectionPoolItem) Insert(tableName string, insert map[string]interface{}, isIgnore bool) (int64, error)
- func (connectionItem *ConnectionPoolItem) InsertArray(tableName string, columnList []string, insertDataList [][]interface{}) error
- func (connectionItem *ConnectionPoolItem) InsertOrUpdate(tableName string, insert map[string]interface{}) error
- func (connectionItem *ConnectionPoolItem) Ping() error
- func (connectionItem *ConnectionPoolItem) Query(query string, args ...interface{}) error
- func (connectionItem *ConnectionPoolItem) Update(query string, args ...interface{}) (int64, error)
- type TransactionStruct
- func (transactionItem *TransactionStruct) Commit() error
- func (transactionItem *TransactionStruct) ExecQuery(query string, args ...interface{}) error
- func (transactionItem *TransactionStruct) FetchQuery(query string, args ...interface{}) (map[string]string, error)
- func (transactionItem *TransactionStruct) GetAll(query string, args ...interface{}) (map[int]map[string]string, error)
- func (transactionItem *TransactionStruct) InsertArray(tableName string, columnList []string, insertDataList [][]interface{}, ...)
- func (transactionItem *TransactionStruct) InsertOrUpdate(tableName string, insert map[string]interface{}) error
- func (transactionItem *TransactionStruct) Rollback() error
- func (transactionItem *TransactionStruct) Update(query string, args ...interface{}) (int64, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReplaceConnection ¶
ReplaceConnection обновить объект подключения
Types ¶
type ConnectionPoolItem ¶
ConnectionPoolItem структура объекта подключения к базе данных
func GetMysqlConnection ¶
func GetMysqlConnection(db string, host string, user string, pass string, maxConnections int, isSsl bool, isNeedReconnect bool) *ConnectionPoolItem
GetMysqlConnection получаем конфигурацию main
func (*ConnectionPoolItem) BeginTransaction ¶
func (connectionItem *ConnectionPoolItem) BeginTransaction() (TransactionStruct, error)
BeginTransaction начинаем транзакцию
func (*ConnectionPoolItem) Close ¶
func (connectionItem *ConnectionPoolItem) Close() error
Close закрываем соединение
func (*ConnectionPoolItem) FetchList ¶
func (connectionItem *ConnectionPoolItem) FetchList(query string, args ...interface{}) ([]string, error)
FetchList получаем одномерный массив из запроса
func (*ConnectionPoolItem) FetchQuery ¶
func (connectionItem *ConnectionPoolItem) FetchQuery(query string, args ...interface{}) (map[string]string, error)
FetchQuery получаем ответ после запроса
func (*ConnectionPoolItem) GetAll ¶
func (connectionItem *ConnectionPoolItem) GetAll(query string, args ...interface{}) (map[int]map[string]string, error)
GetAll получаем массив из запроса
func (*ConnectionPoolItem) Insert ¶
func (connectionItem *ConnectionPoolItem) Insert(tableName string, insert map[string]interface{}, isIgnore bool) (int64, error)
Insert осуществляем запрос вставки
func (*ConnectionPoolItem) InsertArray ¶
func (connectionItem *ConnectionPoolItem) InsertArray(tableName string, columnList []string, insertDataList [][]interface{}) error
InsertArray функция для вставки массива записей в базу
func (*ConnectionPoolItem) InsertOrUpdate ¶
func (connectionItem *ConnectionPoolItem) InsertOrUpdate(tableName string, insert map[string]interface{}) error
InsertOrUpdate осуществляем запрос insert or update
func (*ConnectionPoolItem) Ping ¶
func (connectionItem *ConnectionPoolItem) Ping() error
Ping функция для пинга соединения
func (*ConnectionPoolItem) Query ¶
func (connectionItem *ConnectionPoolItem) Query(query string, args ...interface{}) error
Query осуществляем запрос
type TransactionStruct ¶
type TransactionStruct struct {
// contains filtered or unexported fields
}
TransactionStruct структура транзакции
func (*TransactionStruct) Commit ¶
func (transactionItem *TransactionStruct) Commit() error
Commit подтверждаем транзакцию
func (*TransactionStruct) ExecQuery ¶
func (transactionItem *TransactionStruct) ExecQuery(query string, args ...interface{}) error
ExecQuery осуществляем запрос
func (*TransactionStruct) FetchQuery ¶
func (transactionItem *TransactionStruct) FetchQuery(query string, args ...interface{}) (map[string]string, error)
FetchQuery получаем ответ после запроса
func (*TransactionStruct) GetAll ¶
func (transactionItem *TransactionStruct) GetAll(query string, args ...interface{}) (map[int]map[string]string, error)
GetAll получаем массив
func (*TransactionStruct) InsertArray ¶
func (transactionItem *TransactionStruct) InsertArray(tableName string, columnList []string, insertDataList [][]interface{}, isIgnore bool)
InsertArray функция для вставки массива записей в базу
func (*TransactionStruct) InsertOrUpdate ¶
func (transactionItem *TransactionStruct) InsertOrUpdate(tableName string, insert map[string]interface{}) error
InsertOrUpdate осуществляем запрос insert or update
func (*TransactionStruct) Rollback ¶
func (transactionItem *TransactionStruct) Rollback() error
Rollback откатываем транзакцию
Source Files
Click to show internal directories.
Click to hide internal directories.