您的位置:首页 > 编程语言 > Java开发

java将SQL文件导入到数据库

2011-08-10 10:01 399 查看
最近在做一个CMS系统,不免会在CMS安装阶段会有一个Install database阶段,需要用到安装数据库,之前已经用mysqldunp命令到处一个sql格式的文件,现在需要将它导入数据库。由于java里没有直接针对于数据库的文件操作。只能考虑其他办法:这里是采用读取文件拼接成字符串,并批量处理(addBatch)的方式:代码如下:

private static File file = new File("E:\\data\\tulufan.sql");
private static InputStreamReader fileReader;
static {
try {
if (!file.exists()) {
file.createNewFile();
}
fileReader = new InputStreamReader(new FileInputStream(file),
"UTF-8");
} catch (Exception e) {
e.printStackTrace();
}
}

public void readSQLFile() {
BufferedReader bufferedReader = new BufferedReader(fileReader);
try {
StringBuilder sBuilder = new StringBuilder("");
String str = bufferedReader.readLine();
while (str != null) {
// 去掉一些注释,和一些没用的字符
if (!str.startsWith("#") && !str.startsWith("/*")
&& !str.startsWith("–") && !str.startsWith("\n"))
sBuilder.append(str);
str = bufferedReader.readLine();
}
String[] strArr = sBuilder.toString().split(";");
List<String> strList = new ArrayList<String>();
for (String s : strArr) {
strList.add(s);
System.out.println(s);
}
// 创建数据连接对象,下面的DBConnection是我的一个JDBC类
DBConnection db = new DBConnection();
db.executeBatchByStatement(strList);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
bufferedReader.close();
fileReader.close();
} catch (Exception e) {
}
}
return true;
}
/*******************************

** DBConnection类中批量处理方法

*/

public boolean executeBatchByStatement(List<String> sqlList) {
boolean ret = false;
if (conn != null) {
Statement stmt = null;
try {
conn.setAutoCommit(false);
stmt = conn.createStatement();
for (String s : sqlList) {
stmt.addBatch(s);
}
stmt.executeBatch();
conn.commit();
ret = true;
} catch (BatchUpdateException e) {
e.printStackTrace();
try {
conn.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
conn.setAutoCommit(true);
if (stmt != null) {
stmt.close();
stmt = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return ret;
}
当然,这只是我个人想出来的一个办法,愚陋之见还望大家批评指教,共同提高啊。。。代码有什么问题的可以QQ我,共同商讨啊。。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: