Java读取解析sql文件，并使用netiler dao执行sql-leadal
最近在做系统数据初始化，采用sql形式导入基础数据，这里记录下编码过程。导出的sql文件已经放在dao目录下了。
先来写个方法读取sql文件：
/**
* 加载解析sql文件
* @param sqlFile
* @return
* @throws Exception
*/
private static List loadSql(String sqlFile) throws Exception {
List sqlList = new ArrayList();
try {
InputStream sqlFileIn = new FileInputStream(sqlFile);
StringBuffer sqlSb = new StringBuffer();
byte[] buff = new byte;
int byteRead = 0;
while ((byteRead = sqlFileIn.read(buff)) != -1) {
sqlSb.append(new String(buff, 0, byteRead,"utf-8"));
}
sqlFileIn.close();
// Windows 下换行是 \r\n, Linux 下是 \n
String[] sqlArr = sqlSb.toString()
.split("(;\\s*\\r\\n)|(;\\s*\\n)");
for (int i = 0; i < sqlArr.length; i++) {
String sql = sqlArr.replaceAll("--.*", "").trim();
if (!sql.equals("")) {
sqlList.add(sql);
}
}
return sqlList;
} catch (Exception ex) {
throw new Exception(ex.getMessage());
}
}
即把sql文件读取出来，解析成单条sql语句。
下面是action执行方法
/**
* 执行sql，初始化系统基础数据
* @return
*/
public Object init(){
List list = new ArrayList();
try {
list = loadSql("D:\\workspace\\com.leadal.netiler.install\\web\\data\\dao\\newclips.sql");
int i=0;
service.setProgess(0);
service.setExecute(true);
int>
for(String sql:list){
if(!service.getExecute()){
service.setProgess(100);
break;
}
service.executeSql(sql);
i++;
service.setProgess(100*i/size);
}
ActionMessage.info("基础数据初始化成功！");
} catch (Exception e) {
e.printStackTrace();
ActionMessage.error("初始化失败!");
}
return this;
}
由于是测试，sql文件直接写了个绝对路径。
service调用dao的executeSql(String sql)方法
netiler dao:
@Dao("Netiler.Install.Init.InitBasicData")
public interface InitBasicDataDao {
@Paramable("sql")
public void executeSql(String sql);
}
Netiler Dao dao文件写法:
这里使用statement，定义了个自动类型的result。
过程中遇到几个问题，一个是返回值的，另一个是sql文件包含指令如#if()时，#if()括号里为空字符，解析时有点问题，最后把#if()换成#if(1==1)
2013/5/31 10:35 补充与修改：
在数据插入后，发现部分中文数据是乱码的，经过初步分析，乱码的位置都很有规律，即总是固定的位置出现中文乱码了。这里得到结果是，字节流解析的时候没有处理中文的问题，因为汉字是占两个字节的，当一个汉字刚好占1024-1025字节时，汉字就被拆开了。
解决的方法有两种，一种是继续使用字节流解析，但是对汉字需要进行特殊处理，即通过对比ASCII码大小来确定是否是汉字而进行拼接操作。这样显然是比较麻烦的，当然肯定可以实现。
这里笔者采用字符流行读取形式进行读取解析，贴上代码
/**
* 加载解析sql 读取方式字符流 行读取
* @param sqlFile
* @return
* @throws Exception
*/
private List loadSql2(String sqlFile) throws Exception{
List sqlList = new ArrayList();
try {
FileReader fr = new FileReader(sqlFile);
BufferedReader br = new BufferedReader(fr);
String s="";
StringBuffer sb = new StringBuffer();
while ((s = br.readLine()) != null) {
if(s.startsWith("/*")||s.startsWith("--")){
}
else if(s.endsWith(";")){
sb.append(s);
sqlList.add(sb.toString());
sb.delete(0, sb.length());
}
else{
sb.append(s);
}
}
fr.close();
br.close();
// for(String sql : sqlList){
// System.out.println("sql:"+sql);
// }
} catch (Exception e) {
throw new Exception(e.getMessage());
}
return sqlList;
}
经过测试，乱码问题得到解决
页:
[1]