Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pdb

package

Go to main page

Versions in this module

v0

v0.0.7

Apr 7, 2026

Changes in this version

+ const DefaultConfigGroup

+ func InitMysqlByDsn(dsn string) (err error)

+ func RunMysqlSchemaUpgrade(conf MysqlConfig) error

+ type RawSql struct

+ func NewRawSql(driverName, dataSourceName string) (*RawSql, error)

+ func (r *RawSql) Close() error

+ func (r *RawSql) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func (r *RawSql) GetDB() *sql.DB

+ func (r *RawSql) Ping(ctx context.Context) error

v0.0.6

Jan 15, 2026

Changes in this version

+ const REDIS_KEY_CANAL_BINLOG_POS

+ func GetAllTables() []string

+ func InitMysql(host, user, password, dbName string, port int32) (err error)

+ func InitMysqlByConfig() error

+ func MapRowToStruct(columns []schema.TableColumn, row []interface{}, dest interface{}) error

+ func MustInitMysqlByConfig()

+ func RegisterDeleteCallback(tableName string, cb DeleteCallback)

+ func RegisterInsertCallback(tableName string, cb InsertCallback)

+ func RegisterUpdateCallback(tableName string, cb UpdateCallback)

+ type CanalClient struct

+ func NewCanal(dbConf MysqlConfig) (*CanalClient, error)

+ func (client *CanalClient) Run() error

+ type DeleteCallback func(ctx context.Context, columns []schema.TableColumn, oldRow []interface{}) error

+ type InsertCallback func(ctx context.Context, columns []schema.TableColumn, newRow []interface{}) error

+ type MyEventHandler struct

+ func (h *MyEventHandler) OnPosSynced(header *replication.EventHeader, pos mysql.Position, set mysql.GTIDSet, ...) error

+ func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error

+ func (h *MyEventHandler) SetDBName(db string)

+ func (h *MyEventHandler) String() string

+ type MysqlConfig struct

+ Mysql SqlConfig

+ type PgsqlConfig struct

+ Pgsql SqlConfig

+ type SqlConfig struct

+ Addr string

+ DbName string

+ Host string

+ Password string

+ Port int32

+ User string

+ func GetSqlConfig() *SqlConfig

+ type TableHandler struct

+ DeleteCallback DeleteCallback

+ InsertCallback InsertCallback

+ UpdateCallback UpdateCallback

+ func GetTableHandler(tableName string) *TableHandler

+ type UpdateCallback func(ctx context.Context, columns []schema.TableColumn, ...) error

+ type Writer struct

+ func (w Writer) Printf(format string, args ...any)

v0.0.5

Aug 7, 2025

v0.0.4

Jul 2, 2025

Changes in this version

+ func Exec(sql string) (sqlResult sql.Result, err error)

+ func ExecFile(path string) (err error)

+ func GetDB() (*sql.DB, error)

+ func GetGormDB() *gorm.DB

+ func GetTables() (ret []string, err error)

+ func InitPG(host, user, password, dbName string, port int32) (err error)

+ func InitPGByConfig() error

+ func MustInitPGByConfig()