auto commit update

src/dashoo.cn/backend/api/business/tmpzcgf/tmpzcgfSession.go

@@ -343,7 +343,7 @@ func (s *TmpzcgtSession) UpdateCertSub() error {
 	var err error
 
 	s.DBE.Query("ALTER TABLE `OilSupplierCertSub` ADD INDEX index_oldid ( `OldId` );")
-	// s.DBE.Query("SET autocommit=0;")
+	s.DBE.Query("SET autocommit=0;")
 	for _, cert := range certList {
 		sql := " UPDATE OilSupplierCertSub b SET b.SupplierId = '" + strconv.Itoa(cert.SupplierId) + "'," +
 			" b.SupplierCertId='"+ strconv.Itoa(cert.Id) + "',"+
@@ -353,9 +353,9 @@ func (s *TmpzcgtSession) UpdateCertSub() error {
 		   // "and b.Type = '1' and b.CreateBy='导入1'"
 
 		_, err = s.DBE.Query(sql)
-		// s.DBE.Query("COMMIT;")
+		s.DBE.Query("COMMIT;")
 	}
-	// s.DBE.Query("SET autocommit=1;")
+	s.DBE.Query("SET autocommit=1;")
 	s.DBE.Query("alter table OilSupplierCertSub drop index index_oldid ;")
 	return err
 }
@@ -543,17 +543,17 @@ func (s *TmpzcgtSession) UpOilSupplierCertAppend() error {
 		"b.SupplierId = IFNULL((SELECT a.`SupplierId` FROM OilSupplierCert a WHERE a.`GfId` = b.OldId AND a.SupplierTypeCode = b.AppendType limit 1), 0), " +
 		"b.SupplierCertId = IFNULL((SELECT a.`Id` FROM OilSupplierCert a WHERE a.`GfId` = b.OldId AND a.SupplierTypeCode = b.AppendType limit 1), 0) " */
 	s.DBE.Query("SET unique_checks=0;")
-	// s.DBE.Query("SET autocommit=0;")
+	s.DBE.Query("SET autocommit=0;")
 
 	sql := "UPDATE OilSupplierCertAppend b left join OilSupplierCert a ON (a.`GfId` = b.OldId AND a.SupplierTypeCode = b.AppendType) SET " +
 		"b.SupplierId = IFNULL(a.`SupplierId`, 0), " +
 		"b.SupplierCertId = IFNULL(a.`Id`, 0) "
 	_, err := s.DBE.Query(sql)
 
-	// s.DBE.Query("commit;")
+	s.DBE.Query("commit;")
 
 	s.DBE.Query("SET unique_checks=1;")
-	// s.DBE.Query("SET autocommit=1;")
+	s.DBE.Query("SET autocommit=1;")
 	return err
 }
 
@@ -576,7 +576,7 @@ func (s *TmpzcgtSession) UpdateOilSupplierCertAppendSub() error {
 	svc.GetEntitysByWhere("OilSupplierCertAppend", "", &certAppendList)
 	var err error
 	s.DBE.Query("SET unique_checks=0;")
-	// s.DBE.Query("SET autocommit=0;")
+	s.DBE.Query("SET autocommit=0;")
 	for _, certAppend := range certAppendList {
 		appendCodeList := strings.Split(certAppend.Remark, ",")
 		appendCodeString := "("
@@ -592,10 +592,10 @@ func (s *TmpzcgtSession) UpdateOilSupplierCertAppendSub() error {
 			", a.`Type`=3 WHERE a.SupplierCertId=" + strconv.Itoa(certAppend.SupplierCertId) +
 			" AND"  + code + ") and a.SupplierCertAppendId=0"
 		_, err = s.DBE.Query(sql)
-		// s.DBE.Query("commit;")
+		s.DBE.Query("commit;")
 	}
 	s.DBE.Query("SET unique_checks=1;")
-	// s.DBE.Query("SET autocommit=1;")
+	s.DBE.Query("SET autocommit=1;")
 	return err
 }