gosql

package module

Go to main page

Versions in this module

v1

v1.0.8

Nov 30, 2022

v1.0.7

Jul 7, 2022

Changes in this version

type MySQLConnection

+ func (db *MySQLConnection) ReplicationSetupByConfig(config *ReplicationInfo)

type ReplicationInfo

+ ChannelName string

+ IgnoreServerIds []string

+ MasterId string

+ MasterPass string

+ MasterUser string

+ func (replica *ReplicationInfo) StringFull() string

v1.0.6

Jun 14, 2022

Changes in this version

type MySQLConnection

+ func (db *MySQLConnection) ReplicationDelete(channel string)

v1.0.5

Dec 8, 2021

Changes in this version

type MySQLConnection

+ func (db *MySQLConnection) MasterStatus() *ReplicationInfo

v1.0.4

Sep 9, 2021

v1.0.3

Sep 9, 2021

v1.0.2

Sep 9, 2021

Changes in this version

type MySQLAdmin

+ func (dba *MySQLAdmin) CheckTableExists(tableName, dbName string) (bool, error)

+ func (dba *MySQLAdmin) DropTable(tableName, dbName string) error

v1.0.1

Apr 25, 2021

Changes in this version

+ type MySQLAdmin struct

+ func (dba *MySQLAdmin) CheckDatabaseExists(dbName string) (bool, error)

+ func (dba *MySQLAdmin) CreateDatabase(dbName, charset, collation string) error

+ func (dba *MySQLAdmin) DropDatabase(dbName string) error

+ func (dba *MySQLAdmin) GetMySQLDBStructure(dbname string, withRoutines, withEvents bool) (*MySQLDBStructure, error)

+ func (dba *MySQLAdmin) RenameDatabase(oldName, newName string) error

+ func (dba *MySQLAdmin) RenameDatabaseWithDebug(oldName, newName string) error

type MySQLConnection

+ func (db *MySQLConnection) Admin() *MySQLAdmin

+ type MySQLDBStructure struct

+ Routines map[string]string

+ Tables map[string]string

v1.0.0

Apr 23, 2021

Changes in this version

+ func ConcatValues(begin string, values []string, delim string, end string) string

+ func GenerateHash() uint32

+ func PrepareStringValue(val interface{}) string

+ type Cell struct

+ Index int

+ Name string

+ Value []byte

+ type InsertStmt struct

+ func (in *InsertStmt) Fields(fields ...string) *InsertStmt

+ func (in *InsertStmt) ReturnGeneratedKey() int64

+ func (in *InsertStmt) Run() (int64, *SQLError)

+ func (in *InsertStmt) String() string

+ func (in *InsertStmt) Value(values ...interface{}) *InsertStmt

+ type MySQLConfig struct

+ DbName string

+ Host string

+ Pass string

+ Port int

+ User string

+ func NewMySQLConfig(host string, port int, user string, password string, dataBase string) *MySQLConfig

+ func (conf *MySQLConfig) String() string

+ type MySQLConnection struct

+ Config *MySQLConfig

+ func CreateMySQLConnection(config *MySQLConfig) (MySQLConnection, error)

+ func GetMySQLConnection(host string, port int, user string, password string, dataBase string) MySQLConnection

+ func NewMySQLConnection(host string, port int, user string, password string, dataBase string) (MySQLConnection, error)

+ func (db *MySQLConnection) Close()

+ func (db *MySQLConnection) Commit() *SQLError

+ func (db *MySQLConnection) CreateMySQLHandler(table string) *MySQLHandler

+ func (db *MySQLConnection) DumpByQuery(query string, tables ...string) ([]string, *SQLError)

+ func (db *MySQLConnection) DumpTable(tableName, whereCond string, limit int) ([]string, *SQLError)

+ func (db *MySQLConnection) ExecuteCall(procedureName string, params ...interface{}) (ResultSet, *SQLError)

+ func (db *MySQLConnection) ExecuteInsert(query string, params ...interface{}) (int64, *SQLError)

+ func (db *MySQLConnection) ExecuteUpdate(query string, params ...interface{}) (int64, *SQLError)

+ func (db *MySQLConnection) Hash() uint32

+ func (db *MySQLConnection) Insert(table string) *InsertStmt

+ func (db *MySQLConnection) Replace(table string) *InsertStmt

+ func (db *MySQLConnection) ReplicationReset()

+ func (db *MySQLConnection) ReplicationSetup(host, user, pass, binlog, pos string)

+ func (db *MySQLConnection) ReplicationStart()

+ func (db *MySQLConnection) ReplicationStatus() *ReplicationInfo

+ func (db *MySQLConnection) ReplicationStop()

+ func (db *MySQLConnection) Rollback() *SQLError

+ func (db *MySQLConnection) Select(query string, params ...interface{}) (ResultSet, *SQLError)

+ func (db *MySQLConnection) SelectNative(query string, params ...interface{}) (*sql.Rows, *SQLError)

+ func (db *MySQLConnection) ShowConfigVariablesLike(pattern string) *MySQLVariables

+ func (db *MySQLConnection) String() string

+ func (db *MySQLConnection) Transaction() *SQLError

+ func (db *MySQLConnection) Update(table string) *UpdateStmt

+ type MySQLConnectionPool struct

+ func NewMySQLConnectionPool(size int, config *MySQLConfig) (*MySQLConnectionPool, error)

+ func (pool *MySQLConnectionPool) CloseAll()

+ func (pool *MySQLConnectionPool) Get() *MySQLConnection

+ func (pool *MySQLConnectionPool) Release(connection *MySQLConnection)

+ func (pool *MySQLConnectionPool) Size() int

+ func (pool *MySQLConnectionPool) String() string

+ type MySQLHandler struct

+ func (handler *MySQLHandler) Close()

+ func (handler *MySQLHandler) HasNext() bool

+ func (handler *MySQLHandler) Next(condition, keyName string, limit int) ResultSet

+ func (handler *MySQLHandler) Prev(condition, keyName string, limit int) ResultSet

+ type MySQLVariables struct

+ func (v *MySQLVariables) Get(vrName string) string

+ func (v *MySQLVariables) GetBool(vrName string) bool

+ func (v *MySQLVariables) GetInt(vrName string) int

+ func (v *MySQLVariables) String() string

+ type ReplicationInfo struct

+ BinlogFile string

+ BinlogPos string

+ MasterHost string

+ SlaveLag int

+ Status bool

+ func (replica *ReplicationInfo) String() string

+ type ResultSet struct

+ Rows []Row

+ func (rs *ResultSet) GetBytes(column interface{}) []byte

+ func (rs *ResultSet) GetInt(column interface{}) int

+ func (rs *ResultSet) GetLong(column interface{}) int64

+ func (rs *ResultSet) GetMetaData() *ResultSetMetaData

+ func (rs *ResultSet) GetString(column interface{}) string

+ func (rs *ResultSet) MergeWith(rs2 ResultSet)

+ func (rs *ResultSet) Next() bool

+ func (rs *ResultSet) Print()

+ func (rs *ResultSet) Size() int

+ type ResultSetMetaData struct

+ func (rsmd *ResultSetMetaData) GetColumnCount() int

+ func (rsmd *ResultSetMetaData) GetColumnName(i int) string

+ func (rsmd *ResultSetMetaData) GetColumnType(i int) string

+ func (rsmd *ResultSetMetaData) Hash() uint32

+ type Row struct

+ Values []Cell

+ func NewRow() Row

+ type SQLError struct

+ Code int

+ Message string

+ func (err *SQLError) Error() error

+ func (err *SQLError) String() string

+ type SQLiteConnection struct

+ func NewSQLiteConnection(path string) (*SQLiteConnection, error)

+ func (con *SQLiteConnection) Close()

+ func (con *SQLiteConnection) ExecuteInsert(query string, params ...interface{}) (int64, error)

+ func (con *SQLiteConnection) ExecuteQuery(query string, params ...interface{}) (ResultSet, error)

+ func (con *SQLiteConnection) ExecuteUpdate(query string, params ...interface{}) (int64, error)

+ type UpdateStmt struct

+ func (up *UpdateStmt) Limit(limit int) *UpdateStmt

+ func (up *UpdateStmt) Run() (int64, *SQLError)

+ func (up *UpdateStmt) SetField(fName string, fValue interface{}) *UpdateStmt

+ func (up *UpdateStmt) String() string

+ func (up *UpdateStmt) WhereField(fName string, fValue interface{}) *UpdateStmt

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL