java导出mdb文件_Java中Java生成mdb文件工具类

package com.util;

/**  * Java生成mdb文件[MS Access文件]  * 1. 在ClassPath下存一个空的blank.mdb. (也就是在你的项目中包含一个空白的.mdb文件)   * 2. 将项目中的blank.mdb另存到新的路径. (可能是用户选择要导出mdb文件的保存路径)   * 3. 将.mdb作为数据源, 用JDBC ODBC添加数据. 注: jdbc-odbc 在jre中是有的jre/lib/rt.jar. 也就是不需要引入额外的jar包.     注:步骤3中, 你可以执行CREATE Table的SQL语句.     如果你已经知道了DB的SCHEMA, 那更简单了, 你直接在你的项目中包含一个带有SCHEMA的空的.mdb文件, 这样在步骤3的时候, 不需要再做表结构的创建, 只需要做数据插入即可.   */

import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import java.io.OutputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement;

public class AccessUtil {    private String softPath;  private String softAccessPath;    private Connection connection;

private Statement statement;

// 空白mdb文件路径. 直接保存在src/cn/iwoo/dataexport/common/下.  private final String blankMdbFilePath = "com/util/";

// 空白mdb文件名  private final String blankMdbFileName = "blank.mdb";

// 需要保存到的新的mdb文件路径和名  //private String savedMdbFilePathAndName = defaultSavedMdbFilePath + defaultSavedMdbFileName;  private String savedMdbFilePathAndName = softAccessPath + defaultSavedMdbFileName;

// 新mdb文件路径  public static final String defaultSavedMdbFilePath = "C://access//";

// 新mdb文件名  public static final String defaultSavedMdbFileName = "database.mdb";

// mdb文件后缀  public static final String defaultSavedMdbFileExtension = ".mdb";

// 标准的单例模式  private static AccessUtil instance = new AccessUtil();

private AccessUtil() {  }

public static AccessUtil getInstance() {   return instance;  }

/**   *

  * Description: 设置待保存的新的mdb文件路径和名   *

  */  public void setSavedFilePathAndName(String newFilePathAndName) {   this.savedMdbFilePathAndName = newFilePathAndName;  }

/**   *

  * Description: 删除已经存在的mdb文件   *

  */  public void deleteOldMdbFile() throws Exception {   File oldTargetFile = new File(savedMdbFilePathAndName);   if (oldTargetFile.exists()) {    oldTargetFile.delete();   }  }

/**   *

  * Description: 将空白mdb文件拷贝到特定目录   *

  */  public void copyBlankMdbFile(String savePath, String fileName) throws Exception {   InputStream is = this.getClass().getClassLoader().getResourceAsStream(     blankMdbFilePath + blankMdbFileName);   //OutputStream out = new FileOutputStream(savedMdbFilePathAndName);   OutputStream out = new FileOutputStream(savePath + fileName);   byte[] buffer = new byte[1024];   int numRead;   while ((numRead = is.read(buffer)) != -1) {    out.write(buffer, 0, numRead);   }   is.close();   out.close();  }

/**   *

  * Description: 将空白mdb文件拷贝到特定目录http://www.javalearns.com/ *

  */  public void copyBlankMdbFile() throws Exception {   InputStream is = this.getClass().getClassLoader().getResourceAsStream(     blankMdbFilePath + blankMdbFileName);   OutputStream out = new FileOutputStream(savedMdbFilePathAndName);   byte[] buffer = new byte[1024];   int numRead;   while ((numRead = is.read(buffer)) != -1) {    out.write(buffer, 0, numRead);   }   is.close();   out.close();  }    /**   *

  * Description: 打开对mdb文件的jdbc-odbc连接   *

  */  public void connetAccessDB(String path, String fileName) throws Exception {   String savedMdbFilePathAndName = path + fileName;   Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");   String database = "jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ="     + savedMdbFilePathAndName.trim()     + ";DriverID=22;READOnLY=true}";   cOnnection= DriverManager.getConnection(database, "", "");   statement = connection.createStatement();  }    /**   *

  * Description: 打开对mdb文件的jdbc-odbc连接   *

  */  public void connetAccessDB() throws Exception {   Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");   String database = "jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ="     + savedMdbFilePathAndName.trim()     + ";DriverID=22;READOnLY=true}";   cOnnection= DriverManager.getConnection(database, "", "");   statement = connection.createStatement();  }

/**   *

  * Description: 执行特定sql语句http://www.javalearns.com/ *

  */  public void executeSql(String sql) throws Exception {   statement.execute(sql);  }

/**   *

  * Description: 关闭连接   *

  */  public void closeConnection() throws Exception {   if(statement != null)    statement.close();      if(connection != null)    connection.close();  }

public static void main(String[] args) {   AccessUtil au = AccessUtil.getInstance();   //String sql = "Create Table main ( ID integer, title string, image_ID integer,href_ID integer,text_ID integer,audio_ID integer,dv_ID integer ); ";   //String sql = "create table Archives_tbl (LLR MEMO,LLRQ MEMO,QZH MEMO,MLH MEMO,AJH MEMO,DH MEMO,BGJH MEMO,FLJH MEMO,MJ MEMO,AJBT MEMO,ND MEMO,DW MEMO,JS MEMO,YC MEMO,BGQX MEMO,QSRQ MEMO,JZRQ MEMO,BZ MEMO);";   String sql1 = "create table Archives_tbl (QZH MEMO,MLH MEMO,AJH MEMO,DH MEMO,BGJH MEMO,FLJH MEMO,MJ MEMO,AJBT MEMO,ND MEMO,DW MEMO,JS MEMO,YS MEMO,BGQX MEMO,QSRQ MEMO,JZRQ MEMO,BZ MEMO);";   String sql2 = "create table Files_tb1 (SXH MEMO,WH MEMO,TM MEMO,ZRZ MEMO,ZTC MEMO,RQ MEMO,YC MEMO,YS MEMO,MJ MEMO,LDPSR MEMO,GB MEMO,QTZT MEMO,BZ MEMO,DH MEMO,Vpath MEMO);";           try {    au.copyBlankMdbFile();    au.connetAccessDB();    au.executeSql(sql1);    au.executeSql(sql2);    au.closeConnection();   } catch (Exception e) {    // TODO Auto-generated catch block    e.printStackTrace();   }  }

public void setSoftPath(String softPath) {   this.softPath = softPath;  }

public void setSoftAccessPath(String softAccessPath) {   this.softAccessPath = softAccessPath;  }

}