基于jsp简单的BBS论坛

package bbs.wanggan.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=jbb“; 
       
        try {
				con= DriverManager.getConnection（url“sa““123456“）;
		} 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				    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; 
	   }
     
     
     
     
     
     
     

   
   }