dboperator

Jan 11, 2025

Changes in this version

+ type DMOperator struct

+ func (o DMOperator) Close(dbName string) error

+ func (o DMOperator) CreateSchema(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ func (o DMOperator) ExecuteDDL(ctx context.Context, dbName, ddlStatement string) (err error)

+ func (o DMOperator) GetColumns(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ func (o DMOperator) GetColumnsUnderTables(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ func (o DMOperator) GetDataBySQL(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ func (o DMOperator) GetTableData(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ func (o DMOperator) GetTablesUnderDB(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ func (o DMOperator) Open(config *gormx.Config) error

+ func (o DMOperator) Ping(dbName string) error

type IOperator

+ func NewDMOperator() IOperator

+ func NewSQLiteOperator() IOperator

+ type SQLiteOperator struct

+ func (m SQLiteOperator) Close(dbName string) error

+ func (m SQLiteOperator) CreateSchema(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ func (m SQLiteOperator) ExecuteDDL(ctx context.Context, dbName, ddlStatement string) (err error)

+ func (m SQLiteOperator) GetColumns(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ func (m SQLiteOperator) GetColumnsUnderTables(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ func (m SQLiteOperator) GetDataBySQL(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ func (m SQLiteOperator) GetTableData(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ func (m SQLiteOperator) GetTablesUnderDB(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ func (m SQLiteOperator) Open(config *gormx.Config) error

+ func (m SQLiteOperator) Ping(dbName string) error

+ type SQLiteTableColumn struct

+ ColumnName string

+ DataType string

+ IsNullable int8

+ OrdinalPosition int

+ PrimaryKey int8

Oct 20, 2023

Changes in this version

+ type ColumnInfo struct

+ ColumnName string

+ Comment string

+ DataType string

+ type GPOperator struct

+ func (G GPOperator) Close(dbName string) error

+ func (G GPOperator) CreateSchema(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ func (G GPOperator) ExecuteDDL(ctx context.Context, dbName, ddlStatement string) (err error)

+ func (G GPOperator) GetColumns(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ func (G GPOperator) GetColumnsUnderTables(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ func (G GPOperator) GetDataBySQL(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ func (G GPOperator) GetTableData(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ func (G GPOperator) GetTablesUnderDB(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ func (G GPOperator) Open(config *gormx.Config) error

+ func (G GPOperator) Ping(dbName string) error

+ type GormDBTable struct

+ Comments string

+ TableName string

+ TableSchema string

+ type GormTableColumn struct

+ ColumnName string

+ Comments string

+ DataType string

+ TableName string

+ TableSchema string

+ type IConnector interface

+ Close func(dbName string) error

+ Open func(config *gormx.Config) error

+ Ping func(dbName string) error

+ type IDataExplorer interface

+ CreateSchema func(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ ExecuteDDL func(ctx context.Context, dbName, ddlStatement string) (err error)

+ GetColumns func(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ GetColumnsUnderTables func(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ GetDataBySQL func(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ GetTableData func(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ GetTablesUnderDB func(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ type IOperator interface

+ func NewGPOperator() IOperator

+ func NewMySQLOperator() IOperator

+ func NewOracleOperator() IOperator

+ func NewPGOperator() IOperator

+ func NewSqlserverOperator() IOperator

+ type LogicDBInfo struct

+ SchemaName string

+ TableInfoList []*TableInfo

+ type MySQLOperator struct

+ func (m MySQLOperator) Close(dbName string) error

+ func (m MySQLOperator) CreateSchema(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ func (m MySQLOperator) ExecuteDDL(ctx context.Context, dbName, ddlStatement string) (err error)

+ func (m MySQLOperator) GetColumns(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ func (m MySQLOperator) GetColumnsUnderTables(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ func (m MySQLOperator) GetDataBySQL(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ func (m MySQLOperator) GetTableData(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ func (m MySQLOperator) GetTablesUnderDB(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ func (m MySQLOperator) Open(config *gormx.Config) error

+ func (m MySQLOperator) Ping(dbName string) error

+ type OracleOperator struct

+ func (o OracleOperator) Close(dbName string) error

+ func (o OracleOperator) CreateSchema(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ func (o OracleOperator) ExecuteDDL(ctx context.Context, dbName, ddlStatement string) (err error)

+ func (o OracleOperator) GetColumns(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ func (o OracleOperator) GetColumnsUnderTables(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ func (o OracleOperator) GetDataBySQL(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ func (o OracleOperator) GetTableData(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ func (o OracleOperator) GetTablesUnderDB(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ func (o OracleOperator) Open(config *gormx.Config) error

+ func (o OracleOperator) Ping(dbName string) error

+ type PGOperator struct

+ func (P PGOperator) Close(dbName string) error

+ func (P PGOperator) CreateSchema(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ func (P PGOperator) ExecuteDDL(ctx context.Context, dbName, ddlStatement string) (err error)

+ func (P PGOperator) GetColumns(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ func (P PGOperator) GetColumnsUnderTables(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ func (P PGOperator) GetDataBySQL(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ func (P PGOperator) GetTableData(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ func (P PGOperator) GetTablesUnderDB(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ func (P PGOperator) Open(config *gormx.Config) error

+ func (P PGOperator) Ping(dbName string) error

+ type Pagination struct

+ Page int64

+ PageCount int64

+ PageSize int64

+ Total int64

+ func (p *Pagination) GetOffset() (offset int64)

+ func (p *Pagination) SetPageCount()

+ type SqlServerOperator struct

+ func (s SqlServerOperator) Close(dbName string) error

+ func (s SqlServerOperator) CreateSchema(ctx context.Context, dbName, schemaName, commentInfo string) (err error)

+ func (s SqlServerOperator) ExecuteDDL(ctx context.Context, dbName, ddlStatement string) (err error)

+ func (s SqlServerOperator) GetColumns(ctx context.Context, dbName string) (dbTableColMap map[string]map[string]*TableColInfo, err error)

+ func (s SqlServerOperator) GetColumnsUnderTables(ctx context.Context, dbName, logicDBName string, tableNames []string) (tableColMap map[string]*TableColInfo, err error)

+ func (s SqlServerOperator) GetDataBySQL(ctx context.Context, dbName, sqlStatement string) (rows []map[string]interface{}, err error)

+ func (s SqlServerOperator) GetTableData(ctx context.Context, dbName, schemaName, tableName string, ...) (rows []map[string]interface{}, err error)

+ func (s SqlServerOperator) GetTablesUnderDB(ctx context.Context, dbName string) (dbTableMap map[string]*LogicDBInfo, err error)

+ func (s SqlServerOperator) Open(config *gormx.Config) error

+ func (s SqlServerOperator) Ping(dbName string) error

+ type TableColInfo struct

+ ColumnInfoList []*ColumnInfo

+ TableName string

+ type TableInfo struct

+ Comment string

+ TableName string