save event to sql_sync_his

liuxiaolong

2020-09-18 328a2022e41a95c68f70c83d04fa3e43ead8bfeb

 dbself.go

@@ -119,11 +119,13 @@
         result := tx.Exec(sql)
         err = result.Error
         if err !=nil {
            return false,result.Error
            logger.Error("ExecuteSqlByGorm err:",err,",sql:",sql)
            return false,err
         }
         if result.RowsAffected == 0{
            logger.Error("ExecuteSqlByGorm fail")
            return false,errors.New("ExecuteSqlByGorm fail")
         if result.RowsAffected == 0 {
            logger.Debug("ExecuteSqlByGorm RowsAffected == 0",",sql:",sql)
            err = errors.New("ExecuteSqlByGorm RowsAffected == 0")
            return false,err
         }
      }
      tx.Commit()
@@ -152,10 +154,12 @@
      var arr []string
      var dumpSql []DumpSql
      for _,table :=range tableNames {
         logger.Info("dump current tableName:", table)
         dumpSql = make([]DumpSql, 0)
         var tDescArr []TableDesc
         tSql := fmt.Sprintf(`PRAGMA table_info("%s")`, table)
         err := localDb.Raw(tSql).Scan(&tDescArr).Error
         logger.Debug("tDescArr err:", err, "len(tDescArr)=", len(tDescArr))
         if err !=nil {
            return nil,errors.New("tableDesc err")
         }
@@ -187,9 +191,9 @@
         logger.Info("tSql:",tSql)

         err = localDb.Raw(tSql).Scan(&dumpSql).Error
         logger.Debug("dump err:", err)
         if err !=nil {
            return nil,errors.New("dump err")
            continue
         }
         if len(dumpSql)>0 {
            for _,d :=range dumpSql {