mysql

Documentation

Index

• type MySQL
  • func New() *MySQL
  • func (ms *MySQL) AlterTable(stmt sqlstmt.Stmt, db, table, pk string, hasPk bool, info driver.Info, ...) (err error)
  • func (ms MySQL) Connect(opt *options.ConnectOptions) (connStr string)
  • func (ms MySQL) CreateDatabase(stmt sqlstmt.Stmt, db string, checkExists bool)
  • func (ms MySQL) CreateIndexes(stmt sqlstmt.Stmt, db, table string, idxs []indexes.Index, supportDesc bool)
  • func (ms MySQL) CreateTable(stmt sqlstmt.Stmt, db, table, pk string, info driver.Info, ...) (err error)
  • func (ms *MySQL) Delete(stmt sqlstmt.Stmt, f *actions.DeleteActions) (err error)
  • func (ms *MySQL) DropColumn(stmt sqlstmt.Stmt, db, table, column string)
  • func (ms MySQL) DropDatabase(stmt sqlstmt.Stmt, db string, checkExists bool)
  • func (ms MySQL) DropIndexes(stmt sqlstmt.Stmt, db, table string, idxs []string)
  • func (ms MySQL) DropTable(stmt sqlstmt.Stmt, db, table string, exists bool)
  • func (ms MySQL) Format(it interface{}) (val string)
  • func (ms *MySQL) GetColumns(stmt sqlstmt.Stmt, dbName, table string)
  • func (ms MySQL) GetDatabases(stmt sqlstmt.Stmt)
  • func (ms MySQL) GetIndexes(stmt sqlstmt.Stmt, dbName, table string)
  • func (ms MySQL) GetVersion(stmt sqlstmt.Stmt)
  • func (ms MySQL) HasIndex(stmt sqlstmt.Stmt, dbName, table string, idx indexes.Index)
  • func (ms MySQL) HasIndexByName(stmt sqlstmt.Stmt, dbName, table, indexName string)
  • func (ms MySQL) HasPrimaryKey(stmt sqlstmt.Stmt, db, table string)
  • func (ms MySQL) HasTable(stmt sqlstmt.Stmt, dbName, table string)
  • func (ms MySQL) InsertInto(stmt sqlstmt.Stmt, db, table, pk string, cache reflext.StructMapper, ...) (err error)
  • func (ms *MySQL) RenameColumn(stmt sqlstmt.Stmt, db, table, oldColName, newColName string)
  • func (ms MySQL) RenameTable(stmt sqlstmt.Stmt, db, oldName, newName string)
  • func (ms MySQL) Replace(stmt sqlstmt.Stmt, db, table string, columns []string, query *sql.SelectStmt) (err error)
  • func (ms *MySQL) Select(stmt sqlstmt.Stmt, f *actions.FindActions, lck options.LockMode) (err error)
  • func (ms *MySQL) SelectStmt(stmt sqlstmt.Stmt, query interface{}) (err error)
  • func (ms MySQL) TruncateTable(stmt sqlstmt.Stmt, db, table string)
  • func (ms *MySQL) Update(stmt sqlstmt.Stmt, f *actions.UpdateActions) (err error)
  • func (ms MySQL) UseDatabase(stmt sqlstmt.Stmt, db string)

Types

type MySQL

type MySQL struct {
	sqlutil.MySQLUtil
	// contains filtered or unexported fields
}

MySQL :

func New

func New() *MySQL

New :

func (*MySQL) AlterTable

func (ms *MySQL) AlterTable(stmt sqlstmt.Stmt, db, table, pk string, hasPk bool, info driver.Info, fields []reflext.StructFielder, cols util.StringSlice, idxs util.StringSlice, unsafe bool) (err error)

AlterTable :

func (MySQL) Connect

func (ms MySQL) Connect(opt *options.ConnectOptions) (connStr string)

Connect :

func (MySQL) CreateDatabase

func (ms MySQL) CreateDatabase(stmt sqlstmt.Stmt, db string, checkExists bool)

CreateDatabase :

func (MySQL) CreateIndexes

func (ms MySQL) CreateIndexes(stmt sqlstmt.Stmt, db, table string, idxs []indexes.Index, supportDesc bool)

CreateIndexes :

func (MySQL) CreateTable

func (ms MySQL) CreateTable(stmt sqlstmt.Stmt, db, table, pk string, info driver.Info, fields []reflext.StructFielder) (err error)

CreateTable :

func (*MySQL) Delete

func (ms *MySQL) Delete(stmt sqlstmt.Stmt, f *actions.DeleteActions) (err error)

Delete :

func (*MySQL) DropColumn

func (ms *MySQL) DropColumn(stmt sqlstmt.Stmt, db, table, column string)

DropColumn :

func (MySQL) DropDatabase

func (ms MySQL) DropDatabase(stmt sqlstmt.Stmt, db string, checkExists bool)

DropDatabase :

func (MySQL) DropIndexes

func (ms MySQL) DropIndexes(stmt sqlstmt.Stmt, db, table string, idxs []string)

DropIndexes :

func (MySQL) DropTable

func (ms MySQL) DropTable(stmt sqlstmt.Stmt, db, table string, exists bool)

DropTable :

func (MySQL) Format

func (ms MySQL) Format(it interface{}) (val string)

Format :

func (*MySQL) GetColumns

func (ms *MySQL) GetColumns(stmt sqlstmt.Stmt, dbName, table string)

GetColumns :

func (MySQL) GetDatabases

func (ms MySQL) GetDatabases(stmt sqlstmt.Stmt)

GetDatabases :

func (MySQL) GetIndexes

func (ms MySQL) GetIndexes(stmt sqlstmt.Stmt, dbName, table string)

GetIndexes :

func (MySQL) GetVersion

func (ms MySQL) GetVersion(stmt sqlstmt.Stmt)

GetVersion :

func (MySQL) HasIndex

func (ms MySQL) HasIndex(stmt sqlstmt.Stmt, dbName, table string, idx indexes.Index)

HasIndex :

func (MySQL) HasIndexByName

func (ms MySQL) HasIndexByName(stmt sqlstmt.Stmt, dbName, table, indexName string)

HasIndexByName :

func (MySQL) HasPrimaryKey

func (ms MySQL) HasPrimaryKey(stmt sqlstmt.Stmt, db, table string)

HasPrimaryKey :

func (MySQL) HasTable

func (ms MySQL) HasTable(stmt sqlstmt.Stmt, dbName, table string)

HasTable :

func (MySQL) InsertInto

func (ms MySQL) InsertInto(stmt sqlstmt.Stmt, db, table, pk string, cache reflext.StructMapper, cdc codec.Codecer, fields []reflext.StructFielder, v reflect.Value, opt *options.InsertOptions) (err error)

InsertInto :

func (*MySQL) RenameColumn

func (ms *MySQL) RenameColumn(stmt sqlstmt.Stmt, db, table, oldColName, newColName string)

RenameColumn :

func (MySQL) RenameTable

func (ms MySQL) RenameTable(stmt sqlstmt.Stmt, db, oldName, newName string)

RenameTable :

func (MySQL) Replace

func (ms MySQL) Replace(stmt sqlstmt.Stmt, db, table string, columns []string, query *sql.SelectStmt) (err error)

Replace :

func (*MySQL) Select

func (ms *MySQL) Select(stmt sqlstmt.Stmt, f *actions.FindActions, lck options.LockMode) (err error)

Select :

func (*MySQL) SelectStmt

func (ms *MySQL) SelectStmt(stmt sqlstmt.Stmt, query interface{}) (err error)

SelectStmt :

func (MySQL) TruncateTable

func (ms MySQL) TruncateTable(stmt sqlstmt.Stmt, db, table string)

TruncateTable :

func (*MySQL) Update

func (ms *MySQL) Update(stmt sqlstmt.Stmt, f *actions.UpdateActions) (err error)

Update :

func (MySQL) UseDatabase

func (ms MySQL) UseDatabase(stmt sqlstmt.Stmt, db string)

UseDatabase :