Documentation
¶
Index ¶
- func CheckTableExists(db *sql.DB, schema, table string) (bool, error)
- func CreateDB(db *sql.DB, dbName string) error
- func CreateNewTable(db *sql.DB, schema string, table string) error
- func GetSyncerCheckpoint(db *sql.DB, id, taskName string) (string, uint32, error)
- func OpenDB(dbConn string) (*sql.DB, error)
- func ShowCreateTable(db *sql.DB, schema, table string) (string, error)
- type CheckerClient
- type DbClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetSyncerCheckpoint ¶
getSyncerCheckpoint returns binlog name, binlog position and error
Types ¶
type CheckerClient ¶
type CheckerClient struct {
}
func NewChecker ¶
func NewChecker() *CheckerClient
func (*CheckerClient) CheckDatabase ¶
func (cc *CheckerClient) CheckDatabase(syncDiffInspectorBinary, syncDiffInsTemplate, sourceId, targetId string, tableId int) bool
check if the current database and target database is the same database.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.