dbo.java

java web开发技术方案宝典

package com.yxq.dao;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import com.yxq.actionform.BranchForm;

public class DBO {
	private String URL;
	private String classname;
	private String username;
	private String password;
	private CreatePage createpage;
	
	private Connection con;
	private CallableStatement stm;
	private ResultSet rs;
	
	public DBO(){
		URL="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=db_FABD01";
		classname="com.microsoft.jdbc.sqlserver.SQLServerDriver";
		username="sa";
		password="";
		createpage=new CreatePage();
	}
	
	private void LoadDriver(){
		try{
			Class.forName(classname);
		}catch(ClassNotFoundException e){
			System.out.println("加载驱动程序失败！");
			e.printStackTrace();
		}
	}
	
	private Connection getCon(){
		LoadDriver();
		try{
	    	con=DriverManager.getConnection(URL,username,password);
		}catch(Exception e){
			System.out.println("创建数据库连接失败！");
			e.printStackTrace();
		}
		return con;
	}
	
	private Statement getStm(String proceName){
		Connection con=getCon();
		try{
			stm=con.prepareCall(proceName,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
		}catch(Exception e){
			System.out.println("创建CallableStatement对象失败！");
			e.printStackTrace();
		}
		return stm;
	}

	public ResultSet menManageSelect(String procName,String sql){
		ResultSet rs=null;
		if(procName!=null&&!procName.equals("")){
			getStm(procName);
			try{
				stm.setString(1,sql);
				rs=stm.executeQuery();
			}catch(Exception e){
				System.out.println("menManagerSelect出错！");
				e.printStackTrace();
			}			
		}
		return rs;
	}
	
	public int menManageAdd(String procName,Map paramMap){
		int i=-1;
		if((procName!=null&&!procName.equals(""))&&(paramMap!=null&&paramMap.size()!=0)){
			getStm(procName);
			try{
				stm.setString(1,(String)paramMap.get("1"));
				stm.setString(2,(String)paramMap.get("2"));
				stm.setString(3,(String)paramMap.get("3"));
				stm.setString(4,(String)paramMap.get("4"));
				stm.setString(5,(String)paramMap.get("5"));
			    i=stm.executeUpdate();			    
			}
			catch(Exception e){
				i=-1;
				e.printStackTrace();
			}
		}
		return i;
	}
	
	public int menManageModify(String procName,Map paramMap){
		int i=-1;
		if((procName!=null&&!procName.equals(""))&&(paramMap!=null&&paramMap.size()!=0)){
			getStm(procName);
			try{
				stm.setString(1,(String)paramMap.get("1"));
				stm.setString(2,(String)paramMap.get("2"));
				stm.setString(3,(String)paramMap.get("3"));
				stm.setString(4,(String)paramMap.get("4"));
				stm.setString(5,(String)paramMap.get("5"));
				stm.setInt(6,(Integer)paramMap.get("6"));
			    i=stm.executeUpdate();
			    
			}
			catch(Exception e){
				i=-1;
				e.printStackTrace();
			}
		}
		return i;
	}
	
	public int menManageDel(String procName,int id){
		int i=-1;
		if(procName!=null&&!procName.equals("")){
			getStm(procName);
			try {
				stm.setInt(1,id);
				i=stm.executeUpdate();
			} catch (SQLException e){
				e.printStackTrace();
			}			
		}		
		return i;		
	}
	
	public List getCurrentList(int currentP,String procName,String sql){
		if(procName==null)
			procName="";
		if(sql==null)
			sql="";
		List<BranchForm> currentlist=new ArrayList<BranchForm>();
		rs=menManageSelect(procName,sql);
		try{
			if(rs!=null){
				if(rs.next()){
					rs.last();
					createpage.setAllR(rs.getRow());
					createpage.setCurrentP(currentP);
					int pos=createpage.getPosR();
					int i=1;
					rs.absolute(pos);
					rs.previous();
					while(rs.next()&&i<=createpage.getPerR()){
						BranchForm branchform=new BranchForm();
						branchform.setId(rs.getInt("id"));
						branchform.setBranchName(rs.getString("branch_name"));
						branchform.setBranchInfo(rs.getString("branch_info"));
						branchform.setBranchManager(rs.getString("branch_manager"));
						branchform.setBranchAddr(rs.getString("branch_addr"));
						branchform.setBranchPhone(rs.getString("branch_phone"));
						i++;
						currentlist.add(branchform);
					}					
				}			
			}
		}catch(Exception e){
			System.out.println("查询分页数据失败！");
			e.printStackTrace();
		}
		finally{
			closed();
		}
		return currentlist;		
	}
	
	public void closed(){
		try {
			if(rs!=null)
			    rs.close();
			if(stm!=null)
				stm.close();
			if(con!=null)
				con.close();
		} catch (SQLException e) {		
			System.out.println("关闭数据库连接失败！");
			e.printStackTrace();
		}
	}
	
	public String getClassname() {
		return classname;
	}
	public void setClassname(String classname) {
		this.classname = classname;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	public String getURL() {
		return URL;
	}
	public void setURL(String url) {
		URL = url;
	}
	public String getUsername() {
		return username;
	}
	public void setUsername(String username) {
		this.username = username;
	}
	public CreatePage getCreatepage() {
		return createpage;
	}
	public void setCreatepage(CreatePage createpage) {
		this.createpage = createpage;
	}	
}