connsql_remote.java

wap站点源码

package sql_db_remote;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.lang.Math.*;

public class ConnSql_remote
{
	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://202.96.137.74:1433;DatabaseName=db_bcbb";
	String strUserName = "sa";
	String strUserPassword = "VQms5w";
	
	public ConnSql_remote(){
	}
	public boolean setConnectDatabase() throws Exception{
		try{
			Class.forName(strDriver).newInstance();
			connection=DriverManager.getConnection(strUrl,strUserName,strUserPassword);
			stmt = connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
			
		}
		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 String CreateId(int sORt){
		boolean isHave=true;
		String aZero="000000";
		String strn="";
		String aId="";
		String isExist="";
		ResultSet rs1;
			while (isHave){
				strn=Integer.toString((int)(1000000*Math.random()));
				aId=aZero.substring(0,(6-strn.length()))+strn;
				if (sORt==1){
					isExist="select Code from wap_User where Code='"+aId+"'";
				}
				else{
					isExist="select Code from wap_Team where Code='"+aId+"'";
				}
				try{
					rs1=stmt.executeQuery(isExist);
				}catch(SQLException eExecuteQuery){
					rs1=null;
					System.out.println("执行查询出错"+eExecuteQuery.getMessage());
					aId=null;
					return aId;
				}
				try{
					isHave=rs1.next();
				}catch(SQLException eExecuteQueryNext){
					isHave=true;
					System.out.println("执行查询出错"+eExecuteQueryNext.getMessage());
					}
			}
		return aId;
	}
	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());
		}
	}
}