ch to Forward

liuxiaolong

2020-05-13 06de16052139afa5671d3ce9fbf4e7c47d65a34b

 sync.go

@@ -63,11 +63,19 @@
   return true
}

func RegisterDbHandler(h sdb.DbHandler) {
type DbHandlerInterface interface {
   sdb.DbHandler
}

type DbDumpHandlerInterface interface {
   sdb.DbDumpHandler
}

func RegisterDbHandler(h DbHandlerInterface) {
   sdb.RegisterDbHandler(h)
}

func RegisterDbDumpHandler(h sdb.DbDumpHandler) {
func RegisterDbDumpHandler(h DbDumpHandlerInterface) {
   sdb.RegisterDbDumpHandler(h)
}

@@ -162,7 +170,7 @@
   //sqls = append(sqls, sqlSync)
   sqls = append(sqls, "PRAGMA foreign_keys=ON")
   sqlDump := strings.Join(sqls, ";")
   if !sdb.DbHandle.Execute(sqlDump) {
   if !sdb.DbHandle.Forward(sqlDump) {
      logger.Debug("sdb.DbHandle.Execute ret: false")
      return false
   } else {