dbconsql.java

jsp bbs 论坛源码

package bbs.ahut.db;
import java.io.Reader;
import java.io.StringReader;
import java.sql.*;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.Token;
import org.apache.lucene.analysis.TokenStream;
import org.mira.lucene.analysis.IK_CAnalyzer;
public class DbConSql{
	
	public Connection getCon(){
        Connection con = null;
	    try {
		    	Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
	    } catch (ClassNotFoundException e1) {
	    		System.out.println("驱动加载错误！");
	    		e1.printStackTrace();
	    }
        
        String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=bbs"; 
       
        try {
				con= DriverManager.getConnection(url,"sa","sa");
		} catch (SQLException e) {
				System.out.println("数据连接错误！");
				e.printStackTrace();
		}
	  return con;
	 }
				  
	
	 public  ResultSet getQuery(String sql){
	     Connection conn=getCon();
		 Statement stt=null;
		 ResultSet rs = null;
		 try{
				 stt=conn.createStatement();
				 rs=stt.executeQuery(sql);
		 }catch(Exception e){
				 e.printStackTrace();
		 }
		return rs;
	  }
		 
	   
		
     public  int insert(String sql){
		 Connection conn=getCon();
		 Statement stt=null;
		 int n=0;
		 try {
				 conn.setAutoCommit(false);
				 stt=conn.createStatement();
				 n=stt.executeUpdate(sql);
				 conn.commit();
		 } catch (SQLException e) {
				 try {
					conn.rollback();
				 } catch (SQLException e1) {
					e1.printStackTrace();
				 }
				 e.printStackTrace();
		 }finally{
				 try {
					 stt.close();
					 conn.close();
				 } catch (SQLException e) {
					e.printStackTrace();
				 }
		  }

          return n; 
	   }
     
     
     public  void delete(String[] sql){
		 Connection conn=getCon();
		 Statement stt=null;
		 try {
				 conn.setAutoCommit(false);
				 stt=conn.createStatement();
				 for(int i=0;i<sql.length;i++){
				    stt.executeUpdate(sql[i]);
				 }
				 conn.commit();
		 } catch (SQLException e) {
				 try {
					conn.rollback();
				 } catch (SQLException e1) {
					e1.printStackTrace();
				 }
				 e.printStackTrace();
		 }finally{
				 try {
					 stt.close();
					 conn.close();
				 } catch (SQLException e) {
					e.printStackTrace();
				 }
		  }

	   }
     
     
     
     public  int update(String sql){
		 Connection conn=getCon();
		 Statement stt=null;
		 int n=0;
		 try {
				 conn.setAutoCommit(false);
				 stt=conn.createStatement();
				 n=stt.executeUpdate(sql);
				 conn.commit();
		 } catch (SQLException e) {
				 try {
					conn.rollback();
				 } catch (SQLException e1) {
					e1.printStackTrace();
				 }
				 e.printStackTrace();
		 }finally{
				 try {
					 stt.close();
					 conn.close();
				 } catch (SQLException e) {
					e.printStackTrace();
				 }
		  }

          return n; 
	   }
     
     
     
     
     
     
     

   
     public static void main(String[] args) {
    	 
//    	 DbConSql db=new DbConSql();
//        // db.insert("insert into users (userno,username)  values('3','4')");
//    	 ResultSet rs=db.getQuery("select * from zhuTie where id=26");
//    	 try {
//			while(rs.next()){
//				 int s=rs.getInt("id");
//				 System.out.print(s);
//			 }
//		} catch (SQLException e) {
//			e.printStackTrace();
//		}
    	
     }

}