JDBC更新一个大表的速度怎么那么慢？

Question

我用的是Sql server数据库，表大约有150万条纪录
在Java程序中使用Sql语句更新表中的一条纪录，要花超过30秒的时间。但使用查询分析器执行该语句，在1秒内即可执行完毕。请大家指教！

Answer 1

差别不会这么大吧sql语句一样吗?是本机吗?code贴出来看看

Answer 2

同样是修改咋就差别这么大捏~~
1.是不是你CODE里面还有别的逻辑处理?如果是单改的话速度肯定差不了这么多.
2.看看是不是内存不够,IDE运行起来缓慢?

Answer 3

sql = "update t_stat_hour_user set FNum = FNum + 1 where user_mobile = ? and USSDPortal = ? and time_begin = ? ";conn = DBConnectionPool.getInstance().getConnection();
pstmt = conn.prepareStatement(sql);....//参数赋值pstmt.executeUpdate(); //这个语句需要30多秒才返回注:t_stat_hour_user对user_mobile+USDDPortal+time_begin建立了唯一索引。

Answer 4

你这个sql在修改参数后和你在查询分析器里面的完全一样吗？主要是where语句，一定一样吗？

Answer 5

我把原来的函数精简了, 结果一样, 下面是完整的函数:
private void updateStatTable(Req2DBReq req)
    {
        String sql = "update t_stat_hour_user set FNum = FNum + 1 where user_mobile = ? and USSDPortal = ? and time_begin = ? ";       
        Connection conn = null;
        PreparedStatement pstmt = null;        try
        {
            Date now = new Date();            conn = DBConnectionPool.getInstance().getConnection();
            pstmt = conn.prepareStatement(sql);            GregorianCalendar timeBegin = null;            timeBegin = new GregorianCalendar();
            timeBegin.setTime(now);
            timeBegin.set(GregorianCalendar.MINUTE, 0);
            timeBegin.set(GregorianCalendar.SECOND, 0);
            timeBegin.set(GregorianCalendar.MILLISECOND, 0);
                        
            pstmt.setString(1, req.getMobile());
            pstmt.setString(2, req.getUSSDPortal());
            pstmt
                .setTimestamp(3, new Timestamp(timeBegin.getTime().getTime()));
            pstmt.executeUpdate(); 
        }
        catch (SQLException e)
        {
            DsmpProxyApp.getLog().error(
                "数据库操作错误(Req2DBHandler):" + e.getMessage());
        }
        finally
        {
            DBTools.close(conn, pstmt, null);
            conn = null;
            pstmt = null;
        }    }

Answer 6

我在查询分析器中执行以下语句, 一瞬间即可完成:update t_stat_hour_user set FNum = FNum + 1 
  where user_mobile = '8613910866967' and USSDPortal = '138*11' and time_begin = cast('2006-12-21 09:00:00' as datetime)

Answer 7

我把代码写成下面这样, 速度就很快了, 难道使用参数复制的方式组装Sql语句会有性能问题?private void updateStatTable(Req2DBReq req)
    {
        String sql = "update t_stat_hour_user set FNum = FNum + 1 " +
                "where user_mobile = '8613910866967' and USSDPortal = '138*11' " +
                "and time_begin = cast('2006-12-21 09:00:00' as datetime)";       
        Connection conn = null;
        PreparedStatement pstmt = null;        try
        {
            Date now = new Date();            conn = DBConnectionPool.getInstance().getConnection();
            pstmt = conn.prepareStatement(sql);            pstmt.executeUpdate(); 
        }
        catch (SQLException e)
        {
            DsmpProxyApp.getLog().error(
                "数据库操作错误(Req2DBHandler):" + e.getMessage());
        }
        finally
        {
            DBTools.close(conn, pstmt, null);
            conn = null;
            pstmt = null;
        }    }

Answer 8

Req2DBReq会有问题吗？你干吗不试试sql=".... where user_mobile = ? and USSDPortal = ? .... "pstmt.setString(1, "86....."); //但愿那个测试的是假号码

Answer 9

不用ReqDBReq我试了一下, 还是同样慢。

Answer 10

"where user_mobile = '8613910866967' and USSDPortal = '138*11' " +
//'8613910866967' 但愿是假号码

Answer 11

调试一下，看看到底具体那一段执行时间长，然后想办法优化这一段。标准的SQL都很快的，用了上层的一些函数就会数量级的慢。

Answer 12

可能是sqlserver的jdbc驱动里对prepareStatement的处理方式的问题

Answer 13

我查了些资料, 好像是数据库处理prepareStatement使用的执行计划于普通Statement的执行计划不同。

Answer 14

我试了微软的jdbc驱动和JDTS, 结果一样。

Answer 15

看来只能先使用普通Statement语句组装Sql了, 原语句有90多个参数, 会是一条非常丑陋的语句。唉...

Answer 16

用statement保证快，你这里其实用statement就可以了，没必要用preparedStatement

Answer 17

如果在程序上找不到bug的话，我猜是以下原因：
1）你执行的读表记录的语句可能读的是服务器内存cache里面的值，这时由于没有实际访问硬盘（或磁盘阵列），速度非常快；而你update表记录时，由于由实际的访问硬盘和写操作的时间，于是速度就相差很大了。
可以考虑引入新的缓存管理技术，一般的公司在做项目时，这部分都是用现成的应用服务器或DBMS提供的，其性能的好坏无法得知。
2）看看你的连接池的实现，连接池的性能好坏很是影响对数据的操作速度。

Answer 18

preparedStatement第1次会比较慢,接下来如果相同的语句,参数不同就会比较快了

Answer 19

呵呵...
这样写也好..
就是用到了工厂模式..还有着只是一小部分的内容:能看懂的...
package com.sccp.dbUtil;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Hashtable;
import java.util.Properties;
import java.util.Vector;public class ConnectionPool { private static String SQL_CONFIG = "SqlConfig.cfg"; private static final String driver = "driver"; private static final String connection = "connection"; private static final String name = "name"; private static String password = "password"; private static Properties property = SqlConfig.sql_Init(SQL_CONFIG); private final int MAX_CONNECTION = 4; private Vector vectPool = new Vector(); private String dataBaseURL; private static ConnectionPool conPool; ConnectionPool() {
}; private static Hashtable poolSources = new Hashtable(); private int innum = 0; private int outnum = 0; private int closenum = 0; /*
 * 返回主数据库链接池
 * */
public synchronized static ConnectionPool getConnectionPool() {
if (conPool == null)
conPool = new ConnectionPool();
return conPool;
} /**/
public synchronized static ConnectionPool getConnectionPool(
String prefixname) {
ConnectionPool pool = (ConnectionPool) poolSources.get(prefixname);
if (pool == null) {
pool = new ConnectionPool();
pool.initDriver();
try { } catch (Exception ex) {
}
poolSources.put(prefixname, pool);
}
return pool;
} /*
 * 得到数据库的连接
 * */
public void initDriver() {
try {
Class.forName((String) property.get(driver));
System.out.println(property.get(driver));
System.out.println(property.get(driver));
} catch (Exception e) {
}
} public synchronized Connection getConnection() {
Connection con = null;
Statement stmt = null;
if (vectPool.size() == 0) {
try {
this.outnum++;
String url = property.getProperty(connection);
System.out.println(url);
System.out.println("0000000000000000000000000");
System.out.println((String) property.getProperty(name));
System.out.println((String) property.getProperty(password));
System.out.println("11111111111111111111111111111111");
con = DriverManager.getConnection(url, (String) property
.getProperty(name), (String) property
.getProperty(password));
System.out.println("connection is success!"); con.setAutoCommit(true);
} catch (SQLException sqle) {
sqle.printStackTrace();
}
} else { con = (Connection) vectPool.remove(0);
this.outnum++;
this.innum--;
}
try {
stmt = con.createStatement();
} catch (SQLException sqle) {
try {
con.close();
} catch (SQLException sqle2) {
sqle2.printStackTrace();
}
con = getConnection();
} finally {
if (stmt != null) {
try {
stmt.close();
} catch (SQLException sqle2) {
sqle2.printStackTrace();
}
}
}
return con;
} /*
 * 释放数据库连接
 * */
public synchronized void poolConncetion(Connection con) {
if (vectPool.size() < MAX_CONNECTION) { if (con == null)
return;
vectPool.addElement(con);
this.innum++;
this.outnum--;
} else {
try {
con.close();
this.closenum++;
} catch (Exception e) {
}
}
} /*
 * 率新数据库连接池
 * */
public void refrech() {
for (int i = 0; i < vectPool.size(); i++) {
Connection con = (Connection) vectPool.get(i);
try {
con.close();
} catch (Exception e) {
continue;
}
}
vectPool.removeAllElements();
} /**
 * @return Returns the dataBaseURL.
 */
public String getDataBaseURL() {
return dataBaseURL;
} /**
 * @param dataBaseURL The dataBaseURL to set.
 */
public void setDataBaseURL(String dataBaseURL) {
this.dataBaseURL = dataBaseURL;
} /**
 * @return Returns the password.
 */
public String getPassword() {
return password;
} /**
 * @param password The password to set.
 */
public void setPassword(String password) {
this.password = password;
} /**
 * @return Returns the name.
 */
public String getName() {
return name;
} public static void main(String args[]) {
ConnectionPool conp = new ConnectionPool();
conp.initDriver();

conp.getConnection();
}}

Answer 20

preparedStatement在第一次运行的时候慢..在以后的运行中也慢..
在SQL里面它就是很慢的,,
大家可以试一下