hsqldbdao.java

合并几个数据库结构相同的数据库文件。hsql数据库文件合并

package merge;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 * 
 * @author xujing 09-04-07
 *
 */
public class HsqldbDao {
	
	private String ClassString;
	private String ConnectionString;
	private String UserName;
	private String PassWord;

	private Connection Conn;
	private Statement Stmt;

	public HsqldbDao(){
		this.initiate();
	}
	
	/**
	 * 初始化连接参数
	 *
	 */
	public void initiate(){
		this.ClassString="org.hsqldb.jdbcDriver";
		this.ConnectionString="jdbc:hsqldb:hsql://localhost/herbdb";
		this.UserName="sa";
		this.PassWord="";
	}
	
	/**
	 * 设定连接参数
	 * @param Class
	 * @param Connection
	 * @param UserName
	 * @param PassWord
	 */
	public void setConnection(String Class,
			String Connection,String UserName,String PassWord){
		this.ClassString=Class;
		this.ConnectionString=Connection;
		this.UserName=UserName;
		this.PassWord=PassWord;
	}
	
	public void setClassDriver(String classdriver){
		ClassString=classdriver;
	}
	
	public void setConstr(String con){
		ConnectionString=con;
	}
	
	public void setDbUser(String user){
		UserName=user;
	}
	
	public void setDbPass(String pass){
		PassWord=pass;
	}
	
	/**
	 * 开启连接
	 * @return boolean 
	 */
	public boolean openConnection(){
	   boolean mResult=true;
	   try{
		   Class.forName(this.ClassString);
		   if ((this.UserName==null) && (this.PassWord==null)){
			   this.Conn= DriverManager.getConnection(this.ConnectionString);
		   }
		   else{
			   this.Conn= DriverManager.getConnection(this.ConnectionString,
					   this.UserName,this.PassWord);
		   }
		   this.Stmt=this.Conn.createStatement();
		   mResult=true;
	   }catch(Exception e){
		   System.out.println("Can't find org.hsqldb.jdbcDriver!!");
		   System.out.println(e.toString());
		   mResult=false;
	   }
	   return mResult;
	}
	
	/**
	 * 关闭连接
	 *
	 */
	public void closeConnection(){
	   try{
		   this.Stmt.close();
		   this.Conn.close();
	   }catch(Exception e){
		   System.out.println(e.toString());
	   }	
	}
	
	/**
	 * 返回查询结果集
	 * @param SqlString
	 * @return ResultSet
	 */
	public ResultSet executeQuery(String SqlString){
		ResultSet result=null;
	    try{
	    	result=this.Stmt.executeQuery(SqlString);
	    }catch(Exception e){
	    	System.out.println(e.toString());
	    }
	    return result;
	}
	
	/**
	 * 返回数据库更新结果
	 * @param SqlString
	 * @return
	 */
	public int executeUpdate(String SqlString){
		int result=0;
	    try{
	    	result=this.Stmt.executeUpdate(SqlString);
	    }catch(Exception e){
	    	System.out.println(e.toString());
	    }
	    return result; 
	}
	
    public static void main(String[] args) {
       HsqldbDao a=new  HsqldbDao();
       a.setConnection("org.hsqldb.jdbcDriver",
    		   "jdbc:hsqldb:file:sleepdb\\sleepdb" , "sa","" );
       String sql="select * from users";
       a.openConnection();
       ResultSet p=a.executeQuery(sql);
       a.closeConnection();
       try{
    	   while(p.next()){
    		   System.out.println(p.getString("id")+"\t");
           }
       }catch(Exception w){
    	   w.printStackTrace();
       }
    }
}