package test.zip;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.File;import java.io.FileNotFoundException;import java.io.FileReader;import java.io.FileWriter;import java.io.IOException;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.util.ArrayList;import org.apache.commons.dbutils.QueryRunner;import org.apache.commons.dbutils.handlers.BeanListHandler;import com.sun.xml.internal.fastinfoset.Decoder;public class DBtoSql {private static PreparedStatement pstmt = null;private static Connection conn = DBManager.getConnection();private static ResultSet rs;private static String fatherDirecoryName = "k:";private static String srcDirecoryName = "/src";private static String zipDirecoryName = "/port";private static String all_table_file_name_meijiami = "/tablename_meijiami";private static String info_file_name_meijiami = "/info_meijiami";private static String input_file_name_meijiami = "/input_meijiami";private static String output_file_name_meijiami = "/output_meijiami";private static String all_table_file_name_jiami = "/tablename_jiami";private static String info_file_name_jiami = "/info_jiami";private static String input_file_name_jiami = "/input_jiami";private static String output_file_name_jiami = "/output_jiami";private static String zip_name = "/back.rar";private static String unzip_file = "/unzip";// 表名private static void table_name(int type) {String info = TableUtil.getInfoTableName();String input = TableUtil.getInputTableName();String output = TableUtil.getOutputTableName();StringBuffer sb = new StringBuffer();try {File f1 = new File(fatherDirecoryName + srcDirecoryName+ all_table_file_name_meijiami);if (f1.exists()) {System.out.println("文件存在");f1.delete();f1 = null;System.out.println("文件删除");} else {System.out.println("文件不存在");}BufferedWriter out = new BufferedWriter(new FileWriter(fatherDirecoryName + srcDirecoryName+ all_table_file_name_meijiami, true));sb.append(info + "/n" + input + "/n" + output);if (out != null) {if (type == 0) {out.write(EnDeCriyptionUtil.BASE64Encoder(sb.toString()));} else {out.write(sb.toString());}out.close();}} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}// 导出syb_info_12private static void syb_info_1(int type) {// type =0 encyption;type=1 不加密BufferedWriter out;try {StringBuffer sb = new StringBuffer();File f1 = new File(fatherDirecoryName + srcDirecoryName+ info_file_name_meijiami);if (f1.exists()) {System.out.println("文件存在");f1.delete();f1 = null;System.out.println("文件删除");} else {System.out.println("文件不存在");}out = new BufferedWriter(new FileWriter(fatherDirecoryName+ srcDirecoryName + info_file_name_meijiami, true));ArrayList<Info> iList = getEntity(Info.class, TableUtil.getInfoTableName());for (Info info : iList) {String sql2 = "insert into "+ TableUtil.getInfoTableName()+ "(i_id,i_erpcode,c_id_fk,i_name,i_name_english,i_current_num,i_price_average,i_price_total,i_each,i_spec,i_vender_code,i_new_code,i_device_code,"+ "i_device_name,i_producer,i_device_producer,i_location,i_allocation,i_is_land,i_map_code,i_is_inport,"+ "i_ship_name,i_comment,i_adder,i_addtime,i_isdel) "+ " values(" + info.getI_id() + ",'"+ info.getI_erpcode() + "'," + info.getC_id_fk() + ",'"+ info.getI_name() + "','" + info.getI_name_english()+ "'," + info.getI_current_num() + ","+ info.getI_price_average() + ","+ info.getI_price_total() + ",'" + info.getI_each()+ "','" + info.getI_spec() + "','"+ info.getI_vender_code() + "','"+ info.getI_new_code() + "','"+ info.getI_device_code() + "','"+ info.getI_device_name() + "','"+ info.getI_producer() + "','"+ info.getI_device_producer() + "','"+ info.getI_location() + "','" + info.getI_allocation()+ "','" + info.getI_is_land() + "','"+ info.getI_map_code() + "','" + info.getI_is_inport()+ "','" + info.getI_ship_name() + "','"+ info.getI_comment() + "'," + info.getI_adder() + ",'"+ info.getI_addtime() + "','" + info.getI_isdel()+ "');/n";sb.append(sql2);}if (out != null) {if (type == 0) {// out.write(EnDeCriyptionUtil.BASE64Encoder(sb.toString()));out.write(DESCoder.ebotongEncrypto(sb.toString()));out.flush();} else {out.write(sb.toString());out.flush();}}if (out != null) {out.flush();out.close();}} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {ConnectionPool.freeResources(rs, pstmt, conn);}}// 导出syb_input_1private static void syb_input_1(int type) {BufferedWriter out;try {StringBuffer sb = new StringBuffer();File f1 = new File(fatherDirecoryName + srcDirecoryName+ input_file_name_meijiami);if (f1.exists()) {System.out.println("文件存在");f1.delete();f1 = null;System.out.println("文件删除");} else {System.out.println("文件不存在");}out = new BufferedWriter(new FileWriter(fatherDirecoryName+ srcDirecoryName + input_file_name_meijiami, true));ArrayList<Input> iList = getEntity(Input.class, TableUtil.getInputTableName());for (Input input : iList) {String sql2 = "insert into "+ TableUtil.getInputTableName()+ " (in_id,in_num,o_id_fk,in_adder,in_time,"+ "i_id_fk,in_price,in_editCount,in_editContent,in_isdel) "+ " values(" + input.getIn_id() + ","+ input.getIn_num() + "," + input.getO_id_fk() + ","+ input.getIn_adder() + ",'" + input.getIn_time()+ "'," + input.getI_id_fk() + "," + input.getIn_price()+ "," + input.getIn_editCount() + ",'"+ input.getIn_editContent() + "','"+ input.getIn_isdel() + "');/n";sb.append(sql2);}if (out != null) {if (type == 0) {out.write(EnDeCriyptionUtil.BASE64Encoder(sb.toString()));out.flush();} else {out.write(sb.toString());out.flush();}}if (out != null) {out.close();}} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {ConnectionPool.freeResources(rs, pstmt, conn);}}// 导出syb_output_1private static void syb_output_1(int type) {BufferedWriter out;try {StringBuffer sb = new StringBuffer();File f1 = new File(fatherDirecoryName + srcDirecoryName+ output_file_name_meijiami);if (f1.exists()) {System.out.println("文件存在");f1.delete();f1 = null;System.out.println("文件删除");} else {System.out.println("文件不存在");}out = new BufferedWriter(new FileWriter(fatherDirecoryName+ srcDirecoryName + output_file_name_meijiami, true));ArrayList<Output> oList = getEntity(Output.class, TableUtil.getOutputTableName());for (Output output : oList) {String sql2 = "insert into "+ TableUtil.getOutputTableName()+ " (out_id,i_id_fk,out_num,out_price,out_adder,out_time,"+ "out_to,out_editCount,out_editContent,out_isdel)values("+ output.getOut_id() + "," + output.getI_id_fk() + ","+ output.getOut_num() + "," + output.getOut_price()+ "," + output.getOut_adder() + ",'"+ output.getOut_time() + "','" + output.getOut_to()+ "'," + output.getOut_editCount() + ",'"+ output.getOut_editContent() + "','"+ output.getOut_isdel() + "');/n";sb.append(sql2);}if (out != null) {if (type == 0) {out.write(EnDeCriyptionUtil.BASE64Encoder(sb.toString()));out.flush();} else {out.write(sb.toString());out.flush();}}if (out != null) {out.close();}} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {ConnectionPool.freeResources(rs, pstmt, conn);}}// public static void encryption() {//// // syb_input_1(0);// // syb_output_1(0);// syb_info_1(0);// // table_name(0);// }public static void noEncryption() {syb_input_1(1);syb_output_1(1);syb_info_1(1);table_name(1);}public static void decode() {File file = new File(fatherDirecoryName + srcDirecoryName);// 判断文件夹是否存在,如果不存在则创建文件夹if (!file.exists()) {file.mkdir();System.out.println("src 文件创建");} else {System.out.println("src 文件存在,");file.delete();System.out.print("文件删除,");file.mkdir();System.out.print("文件创建");}try {DESCoder.DecryptFile(fatherDirecoryName + zipDirecoryName+ info_file_name_jiami, fatherDirecoryName+ srcDirecoryName + info_file_name_meijiami);DESCoder.DecryptFile(fatherDirecoryName + zipDirecoryName+ input_file_name_jiami, fatherDirecoryName+ srcDirecoryName + input_file_name_meijiami);DESCoder.DecryptFile(fatherDirecoryName + zipDirecoryName+ output_file_name_jiami, fatherDirecoryName+ srcDirecoryName + output_file_name_meijiami);DESCoder.DecryptFile(fatherDirecoryName + zipDirecoryName+ all_table_file_name_jiami, fatherDirecoryName+ srcDirecoryName + all_table_file_name_meijiami);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}public static void encode() {File file = new File(fatherDirecoryName + zipDirecoryName);// 判断文件夹是否存在,如果不存在则创建文件夹if (!file.exists()) {file.mkdir();System.out.println("zip 文件创建");} else {System.out.println("zip 文件存在,");file.delete();System.out.print("文件删除,");file.mkdir();System.out.print("文件创建");}try {DESCoder.EncryptFile(fatherDirecoryName + srcDirecoryName+ info_file_name_meijiami, fatherDirecoryName+ zipDirecoryName + info_file_name_jiami);DESCoder.EncryptFile(fatherDirecoryName + srcDirecoryName+ input_file_name_meijiami, fatherDirecoryName+ zipDirecoryName + input_file_name_jiami);DESCoder.EncryptFile(fatherDirecoryName + srcDirecoryName+ output_file_name_meijiami, fatherDirecoryName+ zipDirecoryName + output_file_name_jiami);DESCoder.EncryptFile(fatherDirecoryName + srcDirecoryName+ all_table_file_name_meijiami, fatherDirecoryName+ zipDirecoryName + all_table_file_name_jiami);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}public static void main(String[] args) {File file = new File(fatherDirecoryName + srcDirecoryName);// 判断文件夹是否存在,如果不存在则创建文件夹if (!file.exists()) {file.mkdir();System.out.println("src 文件创建");} else {System.out.println("src 文件存在,");file.delete();System.out.print("文件删除,");file.mkdir();System.out.print("文件创建");}// encryption();// noEncryption();// encode();// ZipCompress.zip(fatherDirecoryName + zipDirecoryName,// fatherDirecoryName +zip_name);// // 以下是解压、解密// setFatherDirecoryName("");// ZipCompress.unZip(fatherDirecoryName + zip_name, fatherDirecoryName// + unzip_file);// decode();}// // // 以下是解压、解密, 网络用户public static void ddcode() {File file = new File(fatherDirecoryName + srcDirecoryName);// 判断文件夹是否存在,如果不存在则创建文件夹if (!file.exists()) {file.mkdir();System.out.println("src 文件创建");} else {System.out.println("src 文件存在,");file.delete();System.out.print("文件删除,");file.mkdir();System.out.print("文件创建");}// 以下是解压、解密setFatherDirecoryName("");ZipCompress.unZip(fatherDirecoryName + zip_name, fatherDirecoryName+ unzip_file);decode();System.out.println("数据文件目录:" + fatherDirecoryName + zipDirecoryName);System.out.println("数据文件名称:");System.out.println(fatherDirecoryName + zipDirecoryName+ info_file_name_jiami);System.out.println(fatherDirecoryName + zipDirecoryName+ input_file_name_jiami);System.out.println(".....");}private static <T> ArrayList<T> getEntity(Class<T> entityClass,String tbName) {StringBuffer sb = new StringBuffer();sb.append(" select * from " + tbName + " ");// sb.append(" where version = 0 ");ArrayList<T> result = null;Connection conn = null;try {String sql = sb.toString();conn = ConnectionPool.getConnection();QueryRunner qr = new QueryRunner();result = (ArrayList<T>) qr.query(conn, sql, new BeanListHandler(entityClass));} catch (Exception e) {e.printStackTrace();} finally {ConnectionPool.freeResources(null, null, conn);}return result;}public static String getAll_table_file_name() {return fatherDirecoryName + zipDirecoryName+ all_table_file_name_meijiami;}public static String getFatherDirecoryName() {return fatherDirecoryName;}public static void setFatherDirecoryName(String fatherDirecoryName) {DBtoSql.fatherDirecoryName = fatherDirecoryName;}}package test.zip;import java.io.BufferedReader; 你的当前访问异常,请进行认证后继续阅读剩余内容。 提交