使用java实现备份和恢复SQLServer表数据
作者：一头老毅
需求
近来工作中遇到一个问题，内网办公系统中的数据需要导出到外网中进行查询，外网的数据库中还有一些表存储外网的数据，因此无法使用全库备份恢复功能来满足需求。即只从内网数据库中导出若干表的内容至外网数据库的对应表。
其他解决方案：使用SQL Server自身的导出SQL语句的方法其实也可以，但是涉及到几十个表，一一手工导出工作量较大。
因此自己写了个函数，将内网中的表数据导出，根据数据生成insert into 语句，然后使用批处理的方式导入到外网数据库中。
1.表结构的分析
生成insert语句时，不得不面对的是引号的使用，对于int等类型无需引号，但是对于char、text等必须加上引号，一个表动辄几十个字段，人工用数组等方式记录字段的类型、名称再进行处理，也比较耗费精力，尤其是数据表的结构时常还在变化，而且是另一个开发公司在维护，何时变化也不得而知。这里通过分析建表语句完成了自动的字段类型的对应，从而大大减轻了人工维护字段及其类型的工作量。
譬如建表语句如下（在SQL Server企业管理器中选中表，Ctrl+C即可得到），这里存放一个文件中：
CREATE TABLE [Import_BizDescrs] ( [DescrId] [char] (10) COLLATE Chinese_PRC_CI_AS NULL , [DescrType] [char] (20) COLLATE Chinese_PRC_CI_AS NULL , [DescrAt] [datetime] NULL , [Descr] [text] COLLATE Chinese_PRC_CI_AS NULL , [DescrBy] [char] (20) COLLATE Chinese_PRC_CI_AS NULL , [BizId] [char] (10) COLLATE Chinese_PRC_CI_AS NULL , [SampId] [char] (20) COLLATE Chinese_PRC_CI_AS NULL , [AssistTaskId] [char] (20) COLLATE Chinese_PRC_CI_AS NULL , [CreatePerson] [char] (20) COLLATE Chinese_PRC_CI_AS NULL , [CreateDate] [datetime] NULL , [UpdatePerson] [char] (20) COLLATE Chinese_PRC_CI_AS NULL , [UpdateDate] [datetime] NULL ) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY] GO
从以上文字中，做出如下处理，即可获得表名、字段名、字段类型以及附带的是否需要引号。
public static void exportTableDataByCreateSQL(String createSQLFileName){
ArrayList <String> fieldNames = new ArrayList<String>();
ArrayList <String> fieldtypes = new ArrayList<String>();
ArrayList <Boolean> needQuotationMark = new ArrayList<Boolean>();
String tableName = "";
String filePath = "C:\\importSQLs\\";
String tmpString;
try {
BufferedReader reader = new BufferedReader(new FileReader(createSQLFileName));
String line = reader.readLine();
//从第一行获取表名
tableName = line.substring(line.indexOf("[")+1,line.indexOf("]"));;
System.out.println(tableName) ;
//后面获取其他信息
while ((line = reader.readLine()) != null) {
if(line.startsWith(")")){
break;
}
tmpString = line.substring(line.indexOf("[")+1,line.indexOf("]"));
fieldNames.add(tmpString);
line = line.substring(line.indexOf("]")+1);
tmpString = line.substring(line.indexOf("[")+1,line.indexOf("]"));
fieldtypes.add(tmpString);
if(tmpString.contains("char")
||tmpString.contains("text")
||tmpString.contains("datetime")){
needQuotationMark.add(true);
}else{
needQuotationMark.add(false);
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}2.备份表
获取到完整的字段、字段属性后，就可以开始生成SQL文件了，对于值为null的数据，略去相应的插入语句，同时由于是全表全量导入，开始时增加了delete from tableName；的语句
全部代码如下：
public static void exportTableDataByCreateSQL(String createSQLFileName){
ArrayList <String> fieldNames = new ArrayList<String>();
ArrayList <String> fieldtypes = new ArrayList<String>();
ArrayList <Boolean> needQuotationMark = new ArrayList<Boolean>();
String tableName = "";
String filePath = "C:\\importSQLs\\";
String tmpString;
try {
BufferedReader reader = new BufferedReader(new FileReader(createSQLFileName));
String line = reader.readLine();
//从第一行获取表名
tableName = line.substring(line.indexOf("[")+1,line.indexOf("]"));;
//后面获取其他信息
while ((line = reader.readLine()) != null) {
if(line.startsWith(")")){
break;
}
tmpString = line.substring(line.indexOf("[")+1,line.indexOf("]"));
fieldNames.add(tmpString);
line = line.substring(line.indexOf("]")+1);
tmpString = line.substring(line.indexOf("[")+1,line.indexOf("]"));
fieldtypes.add(tmpString);
if(tmpString.contains("char")
||tmpString.contains("text")
||tmpString.contains("datetime")){
needQuotationMark.add(true);
}else{
needQuotationMark.add(false);
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//开始生成insert语句
Connection conn;
try {
Class.forName("net.sourceforge.jtds.jdbc.Driver");
conn = DriverManager.getConnection(GlobalVar.ConnURL,GlobalVar.ConnUser,GlobalVar.ConnPWD);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM " + tableName);
FileWriter writer = new FileWriter(filePath + tableName+".lims2", false);
BufferedWriter bufferedWriter = new BufferedWriter(writer);
bufferedWriter.write("delete from "+tableName + ";");
bufferedWriter.newLine();
while (rs.next()) {
String FieldsString="";
String ValuesString="";
for(int i=0; i< needQuotationMark.size();i++){
tmpString = rs.getString(fieldNames.get(i));
if(tmpString != null){
if(FieldsString.equals("")){
FieldsString += fieldNames.get(i);
ValuesString += (needQuotationMark.get(i)?"'":"")+ tmpString.trim() +(needQuotationMark.get(i)?"'":"");
}else{
FieldsString += "," + fieldNames.get(i);
ValuesString += "," + (needQuotationMark.get(i)?"'":"")+ tmpString.trim() + (needQuotationMark.get(i)?"'":"");
}
}
}
bufferedWriter.write("insert into "+ tableName + "("+FieldsString+") values("+ValuesString+");");
bufferedWriter.newLine();
}
bufferedWriter.close();
writer.close();
rs.close();
stmt.close();
conn.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}调用以上函数时，只需将保存建表语句的sql文件位置作为参数即可，在本项目中，生成的sql文件以.lims2结尾。
3.还原表
由于生成的表数据文件较多，这里写了个批处理文件，将导出的表数据文件和该批处理文件一起拷贝到外网服务器中，运行批处理即完成了导入操作。以后准备写个上传的页面，省去了远程桌面的麻烦。批处理文件如下：
osql -S 127.0.0.1 -U 用户名 -P 密码 -d lims2 -i Import_table1.lims2 -o Rst_Import_table1.log
osql -S 127.0.0.1 -U 用户名 -P 密码 -d lims2 -i import_table2.lims2 -o Rst_import_table2.log
osql -S 127.0.0.1 -U 用户名 -P 密码 -d lims2 -i Import_table3.lims2 -o Rst_Import_table3.log
osql -S 127.0.0.1 -U 用户名 -P 密码 -d lims2 -i import_table4.lims2 -o Rst_import_table4.log
osql -S 127.0.0.1 -U 用户名 -P 密码 -d lims2 -i import_table5.lims2 -o Rst_import_table5.log
........
结语
此方法适用于同步部分表而不是整库的情况，尤其是两个数据库无法直接通信，需要手工同步的场景。
到此这篇关于使用java实现备份和恢复SQLServer表数据的文章就介绍到这了,更多相关java备份和恢复SQLServer表数据内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！