`
gmleegmlee
  • 浏览: 116772 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

public void testStatementAddBatch() public void testConnCommit()

    博客分类:
  • JAVA
阅读更多

   public void testStatementAddBatch()
    {
        Connection conn = null;
        Statement stmt = null;
        try
        {
            conn = getDBConnectionMsSqlBySuperAdmin();
            stmt = conn.createStatement();
            for(int i = 0; i < 100; i++)
            {
                String sql = " sql " + i;
                stmt.addBatch(sql);
            }
            stmt.executeBatch();
        }
        catch(SQLException e)
        {
            e.printStackTrace();
        }
        finally
        {
            
        }
    }
    
//    private boolean insertIntoSpecialDataTableFromList(List insertSqlList, String[] cts, PreparedStatement pstmt, Connection connection)
//    {
//        boolean isExecuteCorrect = false;
//        try
//        {
//            for(int i = 3; i < insertSqlList.size(); i++)
//            {
//                String recorder = (String)insertSqlList.get(i);
//                String[] rs = recorder.split(ResBackupUtil.SPLIT_TAG);
//                for(int k = 0; k < rs.length; k++)
//                {
//                    setObject(pstmt, k + 1, cts[k], rs[k]);
//                }
//                pstmt.addBatch();
//                if(i % FLUSH_COUNT == 0 || i == insertSqlList.size() - 1)
//                {
//                    pstmt.executeBatch();
//                    connection.commit();
//                }
//
//            }
//            isExecuteCorrect = true;
//        }
//        catch(SQLException e)
//        {
//            logger.error(e.getMessage(), e);
//        }
//        return isExecuteCorrect;
//    }
    
//    public void insertGroupInfoListIntoLocationMapping()
//    {
//        clearLocationMappingTable();
//
//        String sql = "insert into LocationMapping values(?,?)";
//        Connection connN3 = null;
//        PreparedStatement ps = null;
//        try
//        {
//            DataUpgradeContext context = DataUpgradeContexManager.getDataUpgradeContex();
//            connN3 = DbUtil.getUepDatabaseConnection("n3common", context);
//            ps = connN3.prepareStatement(sql);
//            executeBatchInsert(ps);
//        }
//        catch(SQLException e)
//        {
//            e.printStackTrace();
//        }
//        catch(DataUpgradeException e)
//        {
//            e.printStackTrace();
//        }
//        finally
//        {
//            DbUtil.closeDB(connN3, ps, null);
//        }
//    }
//
//    private void executeBatchInsert(PreparedStatement ps) throws SQLException
//    {
//        for(int i = 0; i < groupInfoList.size(); i++)
//        {
//            GroupInfo groupInfo = groupInfoList.get(i);
//            ps.setString(1, groupInfo.getOid());
//            ps.setString(2, groupInfo.getName());
//            System.out.println("insert into LocationMapping:" + groupInfo.getName());
//            ps.addBatch();
//            if((i + 1) % FLUSH_COUNT == 0 || (i + 1) == groupInfoList.size())
//            {
//                ps.executeBatch();
//            }
//        }
//
//    }

    public void testConnCommit()
    {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try
        {
            conn = getDBConnectionMsSqlBySuperAdmin();
            conn.setAutoCommit(false);
            for(int i = 0; i < 100; i++)
            {
                String sql = " sql " + i;
                pstmt = conn.prepareStatement(sql);
                pstmt.execute();
                // pstmt.executeQuery();
                // pstmt.executeUpdate();
            }
            conn.commit();
        }
        catch(Exception e)
        {
            if(conn != null)
            {
                try
                {
                    conn.rollback();
                }
                catch(SQLException e1)
                {
                    e.printStackTrace();
                }
            }
        }
        finally
        {
            if(pstmt != null)
            {
                try
                {
                    pstmt.close();
                }
                catch(SQLException e)
                {
                    e.printStackTrace();
                }
            }
            if(conn != null)
            {
                try
                {
                    conn.setAutoCommit(true);
                    conn.close();
                }
                catch(SQLException e)
                {
                    e.printStackTrace();
                }

            }
        }

    }



分享到:
评论

相关推荐

    public void actionPerformed(ActionEvent e)

    public void actionPerformed(ActionEvent e){ if(e.getSource()==登录){ String name=用户名.getText().toString(); String u=null,pwd=null,auth=null; String url="jdbc:odbc:mysql"; ...

    条形图及使用示例.zip

    public void setbarDataFont(Font font);//设置数据字体 public void setbarDetailFont(Font font);设置条形图详细数据内容字体 public void setBarheight(int heigh);设置条形图高度 public void ...

    listView适配器

    public void add(T elem) { } public void addAll(List&lt;T&gt; elem) { } public void updateAll(List&lt;T&gt; elem) { } public void addAllBeforeClean(List&lt;T&gt; elem) {} public void set(T oldElem, T newElem)...

    Java 2实用教程(第三版)实验指导与习题解答

    public static void main(String[] args) { // TODO Auto-generated method stub System.out.println("你好,很高兴学习Java"); //命令行窗口输出"你好,很高兴学习Java" A a=new A(); a.fA(); } } class A {...

    3对象方法重载super构造器.rar

    public void train(Dog dog){ //训练小狗站立、排队、做算术 … } public void train(Monkey monkey){ //训练小猴敬礼、翻筋斗、骑自行车 … } 再例如某个类的一个功能是比较两个城市是否相同,一种方式是按...

    基于java开发的五子棋游戏

    1.public void windowClosed(WindowEvent e){} 窗口被完全关闭时调用的方法 2. public void windowDeactivated(WindowEvent e){} 窗口失去活性时调用的方法 3.public void windowActivated(WindowEvent e){} 窗口被...

    会员登录注册登录系统JSP

    public void setLogname(String name) { logname=name; } public String getLogname() { return logname; } public void setAge(int n) { age=n; } public int getAge() { return age; } public void ...

    my java unit

    public void TestLog(String line) { TestLog.TestLog(line); } // public static RegTestcase regtc=new RegTestcase(new ITestFixture()); public abstract void setUp(); public abstract void tearDown...

    JAVA课程面向对象

    public void setBounds(int a,int b,int width,int height 设置窗口的初始位置是(a,b),即距屏幕左面a个像素、距屏幕上方b个像素;窗口的宽是width,高是height。 public void setSize(int width,int height) 设置...

    柱状图及演示程序.zip

    public void drawLastOneBar();//显示最近的一个柱状图 public void setOneBar(float x, float y, Color color, int barwidth = 6, int type = 0);//设置柱状图内容 public void setTitle(string strtitle, string...

    稿纸(自定义view)

    概述:自定义view,实现稿纸功能,可撤消,可恢复,稿纸可设置大小和拖动,有做限制,防止内存不足的问题出现。 使用方法:将DraftView添加到布局中即可。 接口api: // 获取最大宽度 ...public void doRevert()

    java写微信机器人-Java版微信机器人代码.pdf

    public void setContent(String content) { this.content = content; public String getMessageType() { return messageType; public void setMessageType(String messageType) { this.messageType = messageType; ...

    android好用的框架(封装了数据库,注解,网络,图片缓存的框架)

    public void post( String url, Header[] headers, AjaxParams params, String contentType,AjaxCallBack&lt;? extends Object&gt; callBack) public void post( String url, Header[] headers, HttpEntity entity, ...

    Unity ARKit Plugin 2019最新

    public void RunWithConfigAndOptions(ARKitWorldTackingSessionConfiguration config,UnityARSessionRunOption runOptions) public void RunWithConfig(ARKitWorldTackingSessionConfiguration config) public void...

    java事件监听方法和代码

    如键盘事件KeyEvent对应的接口是: public interface KeyListener extends EventListener { public void keyPressed(KeyEvent ev); public void keyReleased(KeyEvent ev); public void keyTyped(KeyEvent ev); } 这...

    设备管理 java对日项目 SSH框架

    public void setKanris(FdmShisankanriService kanris) { this.kanris = kanris; } public FdlCodeSevice getCode() { return code; } public void setCode(FdlCodeSevice code) { this.code = code; ...

    strutslogin 源码

    public void setCode(String code) { this.code = code; } public java.sql.Date getBirthday() { return birthday; } public void setBirthday(java.sql.Date date) { this.birthday = date; } public...

    仓库管理系统源代码

    public void setId(int id) { this.id = id; } public String getGoodsname() { return goodsname; } public void setGoodsname(String goodsname) { this.goodsname = goodsname; } public String ...

    jsp 博客设计

    public void setClassName(String className) { this.className = className;} public int getId() { return id;} public void setId(int id) { this.id = id;} public String getTitle() { return ...

Global site tag (gtag.js) - Google Analytics