操作数据库的模板

package com.member.struts.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcTemplate implements JdbcSource{

 

 String driver="com.microsoft.jdbc.sqlserver.SQLServerDriver";
 String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=JTTZJGL";
 String username="sa";
 String password="";
 
 private Connection conn;
 private Statement st=null;
 private ResultSet rs=null;
 private PreparedStatement ps=null;
 
 public JdbcTemplate()
 {
 }
 
// static {
//  try {
//   Class.forName(JdbcSource.driver).newInstance(); 
//  } catch (Exception e) {
//   e.printStackTrace();
//   System.out.println("加载驱动出错！");
//  }
// }
 private void createConnection(){
  try {
   Class.forName(JdbcSource.Mysql_driver).newInstance(); 
   conn=DriverManager.getConnection(JdbcSource.Mysql_url);
   conn.setAutoCommit(false);
  } catch (Exception e) {
   e.printStackTrace();
   System.out.println("连接失败！"+e.getMessage());
  }
 }
 
 private void getStatement(){
  this.createConnection();
  try {
   st=conn.createStatement();
  } catch (SQLException e) {
   e.printStackTrace();
   System.out.println("得到状态通道失败！");
  }
 }
 private void getPreparedStatement(String sql){
  this.createConnection();
  try {
   ps=conn.prepareStatement(sql);
  } catch (SQLException e) {
   e.printStackTrace();
   System.out.println("得到预通道失败！");
  }
 }
 // 状态通道下的数据查询
 public ResultSet exeQuery(String sql){
  this.getStatement();
  try {
   rs=st.executeQuery(sql);
  } catch (SQLException e) {
   e.printStackTrace();
   System.out.println("查询出错！");
  }
  return rs;
 }
 
 
    //状态通道下的批处理操作
 public boolean exeBatch(String[] params){
  this.getStatement();
  boolean isCorrect=false;
  try{
   if(params!=null && params.length>0){
    for(int i=0;i<params.length;i++){
     st.addBatch(params[i]);
    }
    st.executeBatch();
    this.runCommit();
    isCorrect=true;
   }
  }catch(Exception e){
   e.printStackTrace();
   System.out.println("状态通道下批处理操作失败！");
   this.runRollback();
  }
  this.close();
  return isCorrect;
 }
 // 预通道下的数据操作
 public boolean exeUpdate(String sql,String[] params){
  boolean isCorrect=false;
  this.getPreparedStatement(sql);
  try{
   if(params != null && params.length>0){
    for(int i=0;i<params.length;i++){
     ps.setString(i+1, params[i]);
    }
   }
   ps.executeUpdate();
   this.runCommit();
   isCorrect=true;
  }catch(SQLException e){
   e.printStackTrace();
   this.runRollback();
   System.out.println("预通道下的数据操作出错！");
  }
  this.close();
  return isCorrect;
 }
 
 
 //得到主键
 public int getPK(String tablename,String pk){
  String sql="select max("+pk+") from "+tablename;
  rs=this.exeQuery(sql);
  try {
   if(rs.next()){
    return rs.getInt(1)+1;
   }
  } catch (SQLException e) {
   e.printStackTrace();
   System.out.println("得到主键出错！"+e.getMessage());
  }
  return 1;
 }
 //事务提交
 public void runCommit(){
     try {
   conn.commit();
  } catch (SQLException e) {
   e.printStackTrace();
   System.out.println("事物提交失败！");
  } 
 }
 //事务回滚
 public void runRollback(){
  try {
   conn.rollback();
  } catch (SQLException e) {
   e.printStackTrace();
   System.out.println("事物回滚失败！");
  }
 }
 //关闭资源
 public void close()
 {
  try {
     if(rs!=null)rs.close();
     if(st!=null)st.close();
     if(conn!=null)conn.close();
  } catch (SQLException e) {
   e.printStackTrace();
  } 
 }

 public Connection getConn() {
  return conn;
 }

 public void setConn(Connection conn) {
  this.conn = conn;
 }

 public ResultSet getRs() {
  return rs;
 }

 public void setRs(ResultSet rs) {
  this.rs = rs;
 }

 public Statement getSt() {
  return st;
 }

 public void setSt(Statement st) {
  this.st = st;
 }
  
 public PreparedStatement getPs() {
  return ps;
 }

 public void setPs(PreparedStatement ps) {
  this.ps = ps;
 }

 
 public static void main(String [] args){
  JdbcTemplate jdbc=new JdbcTemplate();
  //jdbc.exeQuery("select * from hyb");
  /*String sql1="insert into hyb(hyid,name,password,birthday) values(6,'张三','1234',null)";
  String sql2="insert into hyjlb(jlid,integral,hyid) values(3,100,6)";
  String [] sqls={sql1,sql2};
  jdbc.exeBatch(sqls);
  */
  //String sql="insert into hyb(hyid,name,birthday)values(?,?,?)";
  String sql="update hyb set name=?,password=?,address=?,birthday=?,phone=?,email=?,qq=?,demo=? where hyid=?";
  //jdbc.exeUpdate(sql, new String[]{"10","呵呵","1986-05-18"});
  String [] params={"aaa","aaa","西安市","1987-02-19","13958457896","[e-mail]","14779358","暂无","1"};
  sql="insert into hyb(hyid,dlmc,birthday)values(10,'test1',null) ";
  System.out.println(sql);
  jdbc.exeUpdate(sql, new String[]{});
  //jdbc.exeUpdate(sql, params);
  }
   
}