dbmanager.java

自己编写的一个JSP+SERVER的框架, 实际项目已经运用多次,效率很好.

package com.aptech.module.manager;

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

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

/**
 * 数据库连接类
 * @author justin
 *
 */
public class DBManager {
	
    public Connection con;//连接
    public Statement st;//执行SQL语句
    public ResultSet rs;//查询结果集
    int    count;//影响行数
     //连接数据库
    public Connection getConnection(){
     try{
          Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
          con = DriverManager.
          getConnection("jdbc:microsoft:sqlserver://localhost:1433;" +
          		"DatabaseName=qbmrp","sa","");

     }catch(Exception e){
    	 System.out.println("数据库连接失败！");
     }
     return con;
    }
    //执行数据库查询
    public ResultSet queryData(String sql){
      try{
           con = getConnection();
           st  = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
           rs  = st.executeQuery(sql);


      }catch(SQLException a){
    	  System.out.println("数据查询出错！");
      }

       return rs;

    }
    //执行数据更新
    public int updateData(String sql){
	    try{
	         con = getConnection();
	         st = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
	         count = st.executeUpdate(sql);
	         con.close();
	    }catch(SQLException a){
	    	System.out.println("数据更新出错！");
	    }
	
	    return count;
    }
    
    public void closeConn(){
    	try{
    		this.con.close();
    	}catch(Exception e){
    		
    	}
    }
  
//    /**
//     * 连接池连接数据库
//     */
//    public void initConnection() { 
//    	   DataSource ds = null; 
//    	   try{ 
//    	     Context initCtx = new InitialContext(); 
//    	     Context envCtx = (Context) initCtx.lookup("java:comp/env"); 
//    	    //从Context中lookup数据源。
//    	     ds = (DataSource)envCtx.lookup("jdbc/qbmrp"); 
//    	 	if(ds!=null) {
//    		 System.out.println("已经获得DataSource!"); 
//    		 System.out.println("<br>");
//    		 Connection conn = ds.getConnection();
//    		 Statement stmt=conn.createStatement();
//    		 ResultSet rst=stmt.executeQuery("select * from sys_user");
//    		 System.out.println("以下是从数据库中读取出来的数据");
//    		 while(rst.next())
//    		 {
//    			 System.out.println("Name:"+rst.getString("user_no"));
//    			 System.out.println("<br>"); 
//    		 }
//    		}else 
//    			System.out.println("连接失败!"); 
//    		}catch(Exception ne) {
//    			System.out.println(ne);
//    		} 
//    }
//    
//    public static void main(String[] args) {
//    	DBManager db = new DBManager();
//    	db.initConnection();
//    }
//    
//    
//    /**
//     * 关闭数据库（连接池）
//     */
////   public void destroyConnection(){
////	   try { 
////	     if (RS!=null) RS.close(); 
////	     if (stmt!=null) stmt.close(); 
////	     if (con!=null) con.close(); 
////	     System.out.println("数据库成功关闭！"); 
////	   } 
////	   catch(Exception e) { 
////		   System.out.println("数据库繁忙，请按F5刷新页面！"); 
////		   e.printStackTrace(); 
////	   } 
////   }

}