zhutidao.java

简单的BBS系统

package com.zjy.struts.mypackage;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import com.zjy.struts.mybean.Fenye;
import com.zjy.struts.mybean.Zhuti;

public class ZhutiDao {
	public PreparedStatement ps = null;

	public Connection con = null;

	public Statement stmt = null;

	public ResultSet rs = null;

	public Statement stmt1 = null;

	public ResultSet rs1 = null;



	public ZhutiDao() {
		try {
			Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver")
					.newInstance();
			String url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=luntan";
			String user = "sa";
			String password = "";
			con = DriverManager.getConnection(url, user, password);
		} catch (Exception e) {
			// TODO: handle exception
		}
	}

	public List selectZhuti(Fenye fy) {
		List list = new ArrayList();
		try {
			stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			stmt1 = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			String sql = "select * from zhutie";
			rs = stmt.executeQuery(sql);
			if (fy.getShowpage() == 1) {

			} else {
				rs.absolute((fy.getShowpage() - 1) * fy.getShowlist());
				System.out.println((fy.getShowpage() - 1) * fy.getShowlist());
			}
			for (int i = 0; i < 5; i++) {
				Zhuti zt = new Zhuti();
				if (rs.next()) {
					int id = rs.getInt(1);
					zt.setId(id);
					zt.setZhuname(rs.getString(2));
					zt.setZhutitle(rs.getString(3));
					zt.setZhutime(rs.getString(5));
					zt.setChicks(rs.getString(6));
					String sql1 = "select * from huitie where parentid=" + id;
					rs1 = stmt1.executeQuery(sql1);
					if (rs1.last()) {
						zt.setAnswer(rs1.getRow());
					} else {
						zt.setAnswer(0);
					}
					list.add(zt);
				}
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				rs.close();
				stmt.close();
				con.close();
			} catch (Exception e) {
				// TODO: handle exception
			}
		}

		return list;
	}
}