Documentation ¶
Index ¶
- type Database
- func (d Database) AllViews(ctx *sql.Context) ([]sql.ViewDefinition, error)
- func (d Database) CreateTable(ctx *sql.Context, name string, schema sql.PrimaryKeySchema) error
- func (d Database) CreateTrigger(ctx *sql.Context, definition sql.TriggerDefinition) error
- func (d Database) CreateView(ctx *sql.Context, name string, selectStatement string) error
- func (d Database) DropStoredProcedure(ctx *sql.Context, name string) error
- func (d Database) DropTable(ctx *sql.Context, name string) error
- func (d Database) DropTrigger(ctx *sql.Context, name string) error
- func (d Database) DropView(ctx *sql.Context, name string) error
- func (d Database) GetStoredProcedures(ctx *sql.Context) ([]sql.StoredProcedureDetails, error)
- func (d Database) GetTableInsensitive(ctx *sql.Context, tblName string) (sql.Table, bool, error)
- func (d Database) GetTableNames(ctx *sql.Context) ([]string, error)
- func (d Database) GetTriggers(ctx *sql.Context) ([]sql.TriggerDefinition, error)
- func (d Database) GetView(ctx *sql.Context, viewName string) (string, bool, error)
- func (d Database) Name() string
- func (d Database) RenameTable(ctx *sql.Context, oldName, newName string) error
- func (d Database) SaveStoredProcedure(ctx *sql.Context, spd sql.StoredProcedureDetails) error
- type MySQLShim
- func (m *MySQLShim) AllDatabases() []sql.Database
- func (m *MySQLShim) Close()
- func (m *MySQLShim) CreateDatabase(ctx *sql.Context, name string) error
- func (m *MySQLShim) Database(name string) (sql.Database, error)
- func (m *MySQLShim) DropDatabase(ctx *sql.Context, name string) error
- func (m *MySQLShim) Exec(db string, query string) error
- func (m *MySQLShim) HasDatabase(name string) bool
- func (m *MySQLShim) Query(db string, query string) (sql.RowIter, error)
- func (m *MySQLShim) QueryRows(db string, query string) ([]sql.Row, error)
- type Table
- func (t Table) AddColumn(ctx *sql.Context, column *sql.Column, order *sql.ColumnOrder) error
- func (t Table) Close(ctx *sql.Context) error
- func (t Table) CreateCheck(ctx *sql.Context, check *sql.CheckDefinition) error
- func (t Table) CreateForeignKey(ctx *sql.Context, fkName string, columns []string, referencedTable string, ...) error
- func (t Table) CreateIndex(ctx *sql.Context, indexName string, using sql.IndexUsing, ...) error
- func (t Table) CreatePrimaryKey(ctx *sql.Context, columns []sql.IndexColumn) error
- func (t Table) DataLength(ctx *sql.Context) (uint64, error)
- func (t Table) Deleter(ctx *sql.Context) sql.RowDeleter
- func (t Table) DropCheck(ctx *sql.Context, chName string) error
- func (t Table) DropColumn(ctx *sql.Context, columnName string) error
- func (t Table) DropForeignKey(ctx *sql.Context, fkName string) error
- func (t Table) DropIndex(ctx *sql.Context, indexName string) error
- func (t Table) DropPrimaryKey(ctx *sql.Context) error
- func (t Table) GetChecks(ctx *sql.Context) ([]sql.CheckDefinition, error)
- func (t Table) GetForeignKeys(ctx *sql.Context) ([]sql.ForeignKeyConstraint, error)
- func (t Table) GetIndexes(ctx *sql.Context) ([]sql.Index, error)
- func (t Table) Inserter(ctx *sql.Context) sql.RowInserter
- func (t Table) ModifyColumn(ctx *sql.Context, columnName string, column *sql.Column, ...) error
- func (t Table) Name() string
- func (t Table) NumRows(ctx *sql.Context) (uint64, error)
- func (t Table) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)
- func (t Table) Partitions(ctx *sql.Context) (sql.PartitionIter, error)
- func (t Table) Pks() []sql.IndexColumn
- func (t Table) PrimaryKeySchema() sql.PrimaryKeySchema
- func (t Table) RenameIndex(ctx *sql.Context, fromIndexName string, toIndexName string) error
- func (t Table) Replacer(ctx *sql.Context) sql.RowReplacer
- func (t Table) Schema() sql.Schema
- func (t Table) String() string
- func (t Table) Truncate(ctx *sql.Context) (int, error)
- func (t Table) Updater(ctx *sql.Context) sql.RowUpdater
- func (t Table) WithIndexLookup(lookup sql.IndexLookup) sql.Table
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
Database represents a database for a local MySQL server.
func (Database) CreateTable ¶
CreateTable implements the interface sql.TableCreator.
func (Database) CreateTrigger ¶
CreateTrigger implements the interface sql.TriggerDatabase.
func (Database) CreateView ¶
CreateView implements the interface sql.ViewDatabase.
func (Database) DropStoredProcedure ¶
DropStoredProcedure implements the interface sql.StoredProcedureDatabase.
func (Database) DropTrigger ¶
DropTrigger implements the interface sql.TriggerDatabase.
func (Database) GetStoredProcedures ¶
GetStoredProcedures implements the interface sql.StoredProcedureDatabase.
func (Database) GetTableInsensitive ¶
GetTableInsensitive implements the interface sql.Database.
func (Database) GetTableNames ¶
GetTableNames implements the interface sql.Database.
func (Database) GetTriggers ¶
GetTriggers implements the interface sql.TriggerDatabase.
func (Database) RenameTable ¶
RenameTable implements the interface sql.TableRenamer.
func (Database) SaveStoredProcedure ¶
SaveStoredProcedure implements the interface sql.StoredProcedureDatabase.
type MySQLShim ¶
type MySQLShim struct {
// contains filtered or unexported fields
}
MySQLShim is a shim for a local MySQL server. Ensure that a MySQL instance is running prior to using this shim. Note: this may be destructive to pre-existing data, as databases and tables will be created and destroyed.
func NewMySQLShim ¶
NewMySQLShim returns a new MySQLShim.
func (*MySQLShim) AllDatabases ¶
AllDatabases implements the interface sql.MutableDatabaseProvider.
func (*MySQLShim) Close ¶
func (m *MySQLShim) Close()
Close closes the shim. This will drop all databases created and accessed since this shim was created.
func (*MySQLShim) CreateDatabase ¶
CreateDatabase implements the interface sql.MutableDatabaseProvider.
func (*MySQLShim) DropDatabase ¶
DropDatabase implements the interface sql.MutableDatabaseProvider.
func (*MySQLShim) HasDatabase ¶
HasDatabase implements the interface sql.MutableDatabaseProvider.
type Table ¶
type Table struct {
// contains filtered or unexported fields
}
Table represents a table for a local MySQL server.
func (Table) CreateCheck ¶
CreateCheck implements the interface sql.CheckAlterableTable.
func (Table) CreateForeignKey ¶
func (t Table) CreateForeignKey(ctx *sql.Context, fkName string, columns []string, referencedTable string, referencedColumns []string, onUpdate, onDelete sql.ForeignKeyReferenceOption) error
CreateForeignKey implements the interface sql.ForeignKeyAlterableTable.
func (Table) CreateIndex ¶
func (t Table) CreateIndex(ctx *sql.Context, indexName string, using sql.IndexUsing, constraint sql.IndexConstraint, columns []sql.IndexColumn, comment string) error
CreateIndex implements the interface sql.IndexAlterableTable.
func (Table) CreatePrimaryKey ¶
CreatePrimaryKey implements the interface sql.PrimaryKeyAlterableTable.
func (Table) DataLength ¶
DataLength implements the interface sql.StatisticsTable.
func (Table) Deleter ¶
func (t Table) Deleter(ctx *sql.Context) sql.RowDeleter
Deleter implements the interface sql.DeletableTable.
func (Table) DropColumn ¶
DropColumn implements the interface sql.AlterableTable.
func (Table) DropForeignKey ¶
DropForeignKey implements the interface sql.ForeignKeyAlterableTable.
func (Table) DropPrimaryKey ¶
DropPrimaryKey implements the interface sql.PrimaryKeyAlterableTable.
func (Table) GetForeignKeys ¶
GetForeignKeys implements the interface sql.ForeignKeyTable.
func (Table) GetIndexes ¶
GetIndexes implements the interface sql.IndexedTable.
func (Table) Inserter ¶
func (t Table) Inserter(ctx *sql.Context) sql.RowInserter
Inserter implements the interface sql.InsertableTable.
func (Table) ModifyColumn ¶
func (t Table) ModifyColumn(ctx *sql.Context, columnName string, column *sql.Column, order *sql.ColumnOrder) error
ModifyColumn implements the interface sql.AlterableTable.
func (Table) PartitionRows ¶
PartitionRows implements the interface sql.Table.
func (Table) Partitions ¶
Partitions implements the interface sql.Table.
func (Table) Pks ¶
func (t Table) Pks() []sql.IndexColumn
Pks implements sql.PrimaryKeyAlterableTable
func (Table) PrimaryKeySchema ¶
func (t Table) PrimaryKeySchema() sql.PrimaryKeySchema
PrimaryKeySchema implements sql.PrimaryKeyAlterableTable
func (Table) RenameIndex ¶
RenameIndex implements the interface sql.IndexAlterableTable.
func (Table) Replacer ¶
func (t Table) Replacer(ctx *sql.Context) sql.RowReplacer
Replacer implements the interface sql.ReplaceableTable.
func (Table) Updater ¶
func (t Table) Updater(ctx *sql.Context) sql.RowUpdater
Updater implements the interface sql.UpdatableTable.
func (Table) WithIndexLookup ¶
func (t Table) WithIndexLookup(lookup sql.IndexLookup) sql.Table
WithIndexLookup implements the interface sql.IndexAddressableTable.