BeX5后端SQL如何加入事务处理

Howy

示意代码：

import java.math.*;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.*;

import java.sql.SQLException;
import com.justep.system.data.*;

public class MyJob {

public static String doTicketsSQLInsert(String atTable,String byField,String inDate,String isGetSet,String myTGUID,String toVoucher){


      HashMap<String,String> sqlMap = new HashMap<String,String>();


      String sSQL = "INSERT INTO DM_TTickets(fBillTable,fCodeNum,fDateChar,fFieldNum"
                 + ",fStatus,fTGUID,fTimeTick)"
                 + " VALUES('"+atTable+"','"+sNewNum+"','"+inDate+"','"+byField
                 + "','"+isGetSet+"','"+myTGUID+"',GETDATE()"
                 + ")";
      System.out.println("sSQL:"+sSQL);
      sqlMap.put(DatabaseProduct.MSSQL.name(), sSQL);
      int nEffect = SQL.executeUpdate(sqlMap, null, "/CommonHFC/Comm/data");
      //在这里我想立即提交数据库事务，以便其它用户马上可以读到刚才写入的数据。如何做？

}

}

============================================

jishuang

http://bbs.wex5.com/forum.php?mo ... &extra=page%3D1

Howy

按 http://bbs.wex5.com/forum.php?mo ... &extra=page%3D1 的方法改写如下：
import java.math.*;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.*;

import java.sql.SQLException;
import com.justep.system.data.*;

public class MyJob {

public static String doTicketsSQLInsert(String atTable,String byField,String inDate,String isGetSet,String myTGUID,String toVoucher){

        com.justep.system.data.Transaction tx = null;
        tx = new com.justep.system.data.Transaction();

       HashMap<String,String> sqlMap = new HashMap<String,String>();


       String sSQL = "INSERT INTO DM_TTickets(fBillTable,fCodeNum,fDateChar,fFieldNum"
                  + ",fStatus,fTGUID,fTimeTick)"
                  + " VALUES('"+atTable+"','"+sNewNum+"','"+inDate+"','"+byField
                  + "','"+isGetSet+"','"+myTGUID+"',GETDATE()"
                  + ")";
       System.out.println("sSQL:"+sSQL);
       sqlMap.put(DatabaseProduct.MSSQL.name(), sSQL);
      tx.begin(); //改写点
       int nEffect = SQL.executeUpdate(sqlMap, null, "/CommonHFC/Comm/data");
       //在这里我想立即提交数据库事务，以便其它用户马上可以读到刚才写入的数据。如何做？
      tx.commit(); //改写点
      String sTest=""; //这里设置断点，其他用户读表DM_TTickets时，是在被锁中，读等待中。。。
      //DoSomeThing；
}
//方法执行跳出后，其他用户就可以读出DM_TTickets
}

这个方法，不起作用

jishuang

SQL.executeUpdate是平台提供的API，平台自己回去控制事务

自己控制事务看看2楼链接中自己控制事务的案例