dbo.java

java web开发宝典源代码

package com.yxq.bean;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
public class DBO {
	private String URL;
	private String classname;
	private String username;
	private String password;
	private CreatePage createpage;
	
	private Connection con;
	private Statement stm;
	private ResultSet rs;
	
	public DBO(){
		System.out.println("数据构造");
		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(){
		getCon();
		try{
			stm=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);			
		}catch(Exception e){
			System.out.println("创建Statement对象失败！");
			e.printStackTrace();
		}
		return stm;
	}
	
	public ResultSet getRs(String sql){
		getStm();
		try{
			rs=stm.executeQuery(sql);			
		}catch(Exception e){
			System.out.println("查询数据库失败！");
			e.printStackTrace();
		}
		return rs;		
	}
	
	public List getCurrentList(int currentP){
		String sql="select * from tb_object";
		List<SingleObject> currentlist=new ArrayList<SingleObject>();
		ResultSet rs=getRs(sql);
		try{
			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()){
					SingleObject single=new SingleObject();
					single.setId(rs.getInt("id"));
					single.setName(rs.getString("object_name"));
					single.setPrice(rs.getFloat("object_price"));
					single.setImgpath(rs.getString("object_imgpath"));
					single.setHave(rs.getInt("object_have"));
					single.setTruehave(single.getHave());
					single.setBuyN(0);
					single.setMessage("");
					currentlist.add(single);
					i++;
				}				
			}			
		}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.isClosed())
				con.close();
		}catch(Exception e){
			System.out.println("关闭数据库失败！");
			e.printStackTrace();
		}
	}
	
	public CreatePage getCreatepage() {
		return createpage;
	}

	public void setCreatepage(CreatePage createpage) {
		this.createpage = createpage;
	}

	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;
	}
}