Access数据迁移到Oracle的java代码 - JAVA

PE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
ResultSet rsAccess = null;
PreparedStatement psOracle = null;
String createTableSql = "select * from " + accessTableName;
//TODO 删除
System.out.println("查询Access表:"+createTableSql);
String dropTableSql = "drop table "+ oracleTableName;
rsAccess = stAccess.executeQuery(createTableSql);
Map map = getOracleSql(rsAccess, oracleTableName);
//TODO 删除
System.out.println("删除Oracle的表:"+dropTableSql);
psOracle = connOracle.prepareStatement(dropTableSql);
try {
psOracle.execute();
} catch (Exception e) {
System.out.println("异常错误:"+e.getMessage());
}
psOracle = connOracle.prepareStatement((String) map.get("oracleSql"));
psOracle.execute();
Map transColNameMap = (Map)map.get("transColNameMap");
// 循环结果集,将数据插入到Oracle中
ResultSetMetaData meta = rsAccess.getMetaData();
int cols = meta.getColumnCount();
while (rsAccess.next()) {
StringBuffer sbBeginHalf = new StringBuffer();
StringBuffer sbEndHalf = new StringBuffer();
sbBeginHalf.append("insert into " + oracleTableName + "(");

for (int j = 1; j <= cols; j++) {
sbBeginHalf.append((String)transColNameMap.get(meta.getColumnName(j)));
sbBeginHalf.append(j if(("VARCHAR".equals(meta.getColumnTypeName(j))||"DATETIME".equals(meta.getColumnTypeName(j)))&&null!=rsAccess.getString(j)){
sbEndHalf.append("'"+rsAccess.getString(j)+"'");
}else{
sbEndHalf.append(rsAccess.getString(j));
} www.2cto.com
sbEndHalf.append(j }
sbBeginHalf.append(") values (");
sbEndHalf.append(")");
String insertSql = sbBeginHalf.append(sbEndHalf.toString()).toString();
ps Oracle = connOracle.prepareStatement(insertSql);
psOracle.execute();
}
//TODO 删除
System.out.println("插入oracle的表数据:"+oracleTableName);
// 关闭连接
close(rsAccess, stAccess, connAccess);
close(null, psOracle, connOracle);
}
}

}

Access数据迁移到Oracle的java代码(三)