java中批量执行sql语句
2007-12-29 14:19
453 查看
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class tttt {
public static boolean supportBatch(Connection con)
{
try
{
DatabaseMetaData md=con.getMetaData();
return md.supportsBatchUpdates();
}
catch(SQLException e)
{
e.printStackTrace();
}
return false;
}
public static int[] goBatch(Connection con,String[] sqls)
{
if(sqls==null)
{
return null;
}
Statement sm=null;
try
{
sm=con.createStatement();
for(int i=0;i<sqls.length;i++)
{
sm.addBatch(sqls[i]);
}
return sm.executeBatch();
}
catch(SQLException e)
{
e.printStackTrace();
}
return null;
}
/**
* @param args
* @throws IllegalAccessException
* @throws InstantiationException
*/
public static void main(String[] args) throws ClassNotFoundException,SQLException, InstantiationException, IllegalAccessException{
// TODO Auto-generated method stub
String userName="root";
String password="709394";
String[] sqls=new String[2];
sqls[0]="insert into yjyj(username) values('jiejie2ddd')";
sqls[1]="delete from yjyj where username='yunjie'";
//在这里可以自己添加多个需要执行的语句
Connection con=null;
try
{
Class.forName("org.gjt.mm.mysql.Driver").newInstance();
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/yyjj",userName,password);
boolean supportBatch=tttt.supportBatch(con);
System.out.println(supportBatch);
if(supportBatch)
{
int[] results=tttt.goBatch(con, sqls);
}
}
catch(SQLException e)
{
e.printStackTrace();
}
}
}
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class tttt {
public static boolean supportBatch(Connection con)
{
try
{
DatabaseMetaData md=con.getMetaData();
return md.supportsBatchUpdates();
}
catch(SQLException e)
{
e.printStackTrace();
}
return false;
}
public static int[] goBatch(Connection con,String[] sqls)
{
if(sqls==null)
{
return null;
}
Statement sm=null;
try
{
sm=con.createStatement();
for(int i=0;i<sqls.length;i++)
{
sm.addBatch(sqls[i]);
}
return sm.executeBatch();
}
catch(SQLException e)
{
e.printStackTrace();
}
return null;
}
/**
* @param args
* @throws IllegalAccessException
* @throws InstantiationException
*/
public static void main(String[] args) throws ClassNotFoundException,SQLException, InstantiationException, IllegalAccessException{
// TODO Auto-generated method stub
String userName="root";
String password="709394";
String[] sqls=new String[2];
sqls[0]="insert into yjyj(username) values('jiejie2ddd')";
sqls[1]="delete from yjyj where username='yunjie'";
//在这里可以自己添加多个需要执行的语句
Connection con=null;
try
{
Class.forName("org.gjt.mm.mysql.Driver").newInstance();
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/yyjj",userName,password);
boolean supportBatch=tttt.supportBatch(con);
System.out.println(supportBatch);
if(supportBatch)
{
int[] results=tttt.goBatch(con, sqls);
}
}
catch(SQLException e)
{
e.printStackTrace();
}
}
}
相关文章推荐
- 批量执行Sql语句,MySQL存储过程Java复现
- java用addBatch()批量执行sql语句实例
- java批量执行多条Sql语句
- c#实现用SQL池(多线程),定时批量执行SQL语句
- PHP mysqli 增强 批量执行sql 语句的实现代码
- executeBatch()批量执行Sql语句
- Java下拼接执行动态SQL语句
- PHP mysqli 增强 批量执行sql 语句的实现代码
- 批量执行 SQL 语句
- java执行sql语句一直没有响应
- Java中直接执行sql语句,返回List集合
- Java批量插入Oracle语句执行过程
- sql语句批量执行
- plsql 批量执行sql语句的方法
- c#实现用SQL池,多线程定时批量执行SQL语句
- 【Oracle】Oracle批量执行SQL语句
- PL/SQL中批量执行SQL脚本(不可把所有的语句都复制到New SQL Windows)
- 在C#中执行带有GO的批量sql语句
- 关于mysql 执行批量的sql 语句问题:&allowMultiQueries=true
- Oracle批量执行sql语句之禁用所有表的外键