connsql.java.bak

wap站点源码

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

public class ConnSql
{
	public Connection connection = null;
	private Statement stmt = null;
	ResultSet rs = null;
	boolean isConnection = true;
	String strDriver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
	String strUrl = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=pubs";
	String strUserName = "sa";
	String strUserPassword = "";
	
	public ConnSql(){
	}
	public boolean setConnectDatabase() throws Exception{
		try{
			Class.forName(strDriver).newInstance();
			connection=DriverManager.getConnection(strUrl,strUserName,strUserPassword);
			stmt = connection.createStatement();
			
		}
		catch (SQLException e)
		{
			isConnection = false;
			System.out.println("数据库连接出现异常"+e.getMessage());
		}
		return isConnection;
	}
	public boolean setAutoCommit(boolean arg){
		try{
			connection.setAutoCommit(arg);
		}
		catch (SQLException e){
			System.out.println("设置自动提交出现异常"+e.getMessage());
		}
		return isConnection;
	}
	public int executeInsert(String strSql){
		int intRow = 1;
		try{
			intRow = stmt.executeUpdate(strSql);
		}
		catch(SQLException eExecuteQuery){
			intRow = 0;
			System.out.println("执行添加操作出现异常："+eExecuteQuery.getMessage());
		}
		return intRow;
	}
	public ResultSet executeQuery(String strSql){
		try{
			rs = stmt.executeQuery(strSql);
		}
		catch(SQLException eExecuteQuery){
			rs = null;
			System.out.println("执行查询出现异常："+eExecuteQuery.getMessage());
		}
		return rs;
	}
	public int executeUpdate(String strSql){
		int intRow = 1;
		try{
			intRow = stmt.executeUpdate(strSql);
		}
		catch(SQLException eExecuteUpdate){
			intRow = 0;
			System.out.println("执行更新操作出现异常："+eExecuteUpdate.getMessage());
		}
		return intRow;
	}
	public int executeDelete(String strSql){
		int intRow = 1;
		try{
			intRow = stmt.executeUpdate(strSql);
		}
		catch(SQLException eExecuteUpdate){
			intRow = 0;
			System.out.println("删除操作出现异常："+eExecuteUpdate.getMessage());
		}
		return intRow;
	}
	public void closeAll(){
		try{
		if (rs != null){
			rs.close();
			rs = null;
		}
		if (stmt != null){
			stmt.close();
			stmt = null;
		}
		if (connection!= null){
			connection.close();
		}
		}
		catch(SQLException e){
			System.out.println("关闭数据库出现异常："+e.getMessage());
		}
	}
	public void commit(){
		try{
			connection.commit();
		}
		catch(SQLException e){
			System.out.println("提交数据库出现异常："+e.getMessage());
		}
	}
	public void rollback(){
		try{
		connection.rollback();
		}
		catch(SQLException e){
			System.out.println("回滚操作出现异常："+e.getMessage());
		}
	}
}