Documentation
¶
Index ¶
- Constants
- func ClearCaches()
- func ExecuteWithPlugins(connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, ...) (wrappedReturnValue any, wrappedReturnValue2 any, wrappedOk bool, ...)
- func GetDatabaseEngine(props *utils.RWMap[string, string]) (driver_infrastructure.DatabaseEngine, error)
- func GetUnderlyingDriver(name string) driver.Driver
- func RegisterUnderlyingDriver(name string, driver driver.Driver)
- func RemovePluginFactory(code string)
- func RemoveUnderlyingDriver(name string)
- func UsePluginFactory(code string, pluginFactory driver_infrastructure.ConnectionPluginFactory)
- type AwsWrapperConn
- func (c *AwsWrapperConn) Begin() (driver.Tx, error)
- func (c *AwsWrapperConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)
- func (c *AwsWrapperConn) CheckNamedValue(val *driver.NamedValue) error
- func (c *AwsWrapperConn) Close() error
- func (c *AwsWrapperConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)
- func (c *AwsWrapperConn) IsValid() bool
- func (c *AwsWrapperConn) Ping(ctx context.Context) error
- func (c *AwsWrapperConn) Prepare(query string) (driver.Stmt, error)
- func (c *AwsWrapperConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)
- func (c *AwsWrapperConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)
- func (c *AwsWrapperConn) ResetSession(ctx context.Context) error
- func (c *AwsWrapperConn) UnwrapPlugin(pluginCode string) driver_infrastructure.ConnectionPlugin
- type AwsWrapperDriver
- type AwsWrapperMySQLRows
- type AwsWrapperPgRows
- type AwsWrapperResult
- type AwsWrapperRows
- type AwsWrapperStmt
- func (a *AwsWrapperStmt) CheckNamedValue(val *driver.NamedValue) error
- func (a *AwsWrapperStmt) Close() error
- func (a *AwsWrapperStmt) Exec(args []driver.Value) (driver.Result, error)
- func (a *AwsWrapperStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)
- func (a *AwsWrapperStmt) NumInput() int
- func (a *AwsWrapperStmt) Query(args []driver.Value) (driver.Rows, error)
- func (a *AwsWrapperStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)
- type AwsWrapperTx
- type ConnectionPluginChainBuilder
- type PluginFactoryWeight
Constants ¶
View Source
const WEIGHT_RELATIVE_TO_PRIOR_PLUGIN = -1
Variables ¶
This section is empty.
Functions ¶
func ClearCaches ¶
func ClearCaches()
This cleans up all long-standing caches. To be called at the end of program, not each time a Conn is closed.
func ExecuteWithPlugins ¶
func ExecuteWithPlugins( connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, methodName string, executeFunc driver_infrastructure.ExecuteFunc, methodArgs ...any) (wrappedReturnValue any, wrappedReturnValue2 any, wrappedOk bool, wrappedErr error)
func GetDatabaseEngine ¶
func GetDatabaseEngine(props *utils.RWMap[string, string]) (driver_infrastructure.DatabaseEngine, error)
func GetUnderlyingDriver ¶ added in v1.1.0
func RegisterUnderlyingDriver ¶ added in v1.1.0
func RemovePluginFactory ¶
func RemovePluginFactory(code string)
func RemoveUnderlyingDriver ¶ added in v1.1.0
func RemoveUnderlyingDriver(name string)
func UsePluginFactory ¶
func UsePluginFactory(code string, pluginFactory driver_infrastructure.ConnectionPluginFactory)
Types ¶
type AwsWrapperConn ¶
type AwsWrapperConn struct {
// contains filtered or unexported fields
}
func NewAwsWrapperConn ¶
func NewAwsWrapperConn( pluginManager driver_infrastructure.PluginManager, pluginService driver_infrastructure.PluginService, engine driver_infrastructure.DatabaseEngine) *AwsWrapperConn
func (*AwsWrapperConn) CheckNamedValue ¶
func (c *AwsWrapperConn) CheckNamedValue(val *driver.NamedValue) error
func (*AwsWrapperConn) Close ¶
func (c *AwsWrapperConn) Close() error
func (*AwsWrapperConn) ExecContext ¶
func (c *AwsWrapperConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)
func (*AwsWrapperConn) IsValid ¶
func (c *AwsWrapperConn) IsValid() bool
func (*AwsWrapperConn) Prepare ¶
func (c *AwsWrapperConn) Prepare(query string) (driver.Stmt, error)
func (*AwsWrapperConn) PrepareContext ¶
func (*AwsWrapperConn) QueryContext ¶
func (c *AwsWrapperConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)
func (*AwsWrapperConn) ResetSession ¶
func (c *AwsWrapperConn) ResetSession(ctx context.Context) error
func (*AwsWrapperConn) UnwrapPlugin ¶ added in v1.1.0
func (c *AwsWrapperConn) UnwrapPlugin(pluginCode string) driver_infrastructure.ConnectionPlugin
type AwsWrapperDriver ¶
type AwsWrapperDriver struct {
DriverDialect driver_infrastructure.DriverDialect
UnderlyingDriver driver.Driver
}
type AwsWrapperMySQLRows ¶
type AwsWrapperMySQLRows struct {
AwsWrapperRows
}
func (*AwsWrapperMySQLRows) ColumnTypeNullable ¶
func (a *AwsWrapperMySQLRows) ColumnTypeNullable(index int) (bool, bool)
func (*AwsWrapperMySQLRows) ColumnTypeScanType ¶
func (a *AwsWrapperMySQLRows) ColumnTypeScanType(index int) reflect.Type
func (*AwsWrapperMySQLRows) HasNextResultSet ¶
func (a *AwsWrapperMySQLRows) HasNextResultSet() bool
func (*AwsWrapperMySQLRows) NextResultSet ¶
func (a *AwsWrapperMySQLRows) NextResultSet() error
type AwsWrapperPgRows ¶
type AwsWrapperPgRows struct {
AwsWrapperRows
}
func (*AwsWrapperPgRows) ColumnTypeLength ¶
func (a *AwsWrapperPgRows) ColumnTypeLength(index int) (int64, bool)
type AwsWrapperResult ¶
type AwsWrapperResult struct {
// contains filtered or unexported fields
}
func (*AwsWrapperResult) LastInsertId ¶
func (a *AwsWrapperResult) LastInsertId() (int64, error)
func (*AwsWrapperResult) RowsAffected ¶
func (a *AwsWrapperResult) RowsAffected() (int64, error)
type AwsWrapperRows ¶
type AwsWrapperRows struct {
// contains filtered or unexported fields
}
func (*AwsWrapperRows) Close ¶
func (a *AwsWrapperRows) Close() error
func (*AwsWrapperRows) ColumnTypeDatabaseTypeName ¶
func (a *AwsWrapperRows) ColumnTypeDatabaseTypeName(index int) string
func (*AwsWrapperRows) ColumnTypePrecisionScale ¶
func (a *AwsWrapperRows) ColumnTypePrecisionScale(index int) (int64, int64, bool)
func (*AwsWrapperRows) Columns ¶
func (a *AwsWrapperRows) Columns() []string
type AwsWrapperStmt ¶
type AwsWrapperStmt struct {
// contains filtered or unexported fields
}
func (*AwsWrapperStmt) CheckNamedValue ¶
func (a *AwsWrapperStmt) CheckNamedValue(val *driver.NamedValue) error
func (*AwsWrapperStmt) Close ¶
func (a *AwsWrapperStmt) Close() error
func (*AwsWrapperStmt) ExecContext ¶
func (a *AwsWrapperStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)
func (*AwsWrapperStmt) NumInput ¶
func (a *AwsWrapperStmt) NumInput() int
func (*AwsWrapperStmt) QueryContext ¶
func (a *AwsWrapperStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)
type AwsWrapperTx ¶
type AwsWrapperTx struct {
// contains filtered or unexported fields
}
func (*AwsWrapperTx) Commit ¶
func (a *AwsWrapperTx) Commit() error
func (*AwsWrapperTx) Rollback ¶
func (a *AwsWrapperTx) Rollback() error
type ConnectionPluginChainBuilder ¶
type ConnectionPluginChainBuilder struct {
}
func (*ConnectionPluginChainBuilder) GetPlugins ¶
func (builder *ConnectionPluginChainBuilder) GetPlugins( pluginService driver_infrastructure.PluginService, pluginManager driver_infrastructure.PluginManager, props *utils.RWMap[string, string], availablePlugins map[string]driver_infrastructure.ConnectionPluginFactory) ([]driver_infrastructure.ConnectionPlugin, error)
type PluginFactoryWeight ¶
type PluginFactoryWeight struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.