dbuser.java

一个基于struts框架开发的论坛系统,适合学习

package frm;


import java.sql.*;
import java.util.*;


public class DbUser {

	public static boolean register(User u,Connection con) throws SQLException{
		if(u==null || con==null) return false;
		String sql="";
		System.out.println("--Save:"+u);
		sql="insert into frm_user (U_ID,NAME,PASSWD,EMAIL,ICON_FILE,"+
		    "REG_DATE,STATUS,ROLE_ID,LAST_DATE,FROUM_ID,SCORE) values (?,?,?,?,?,"+
		    "sysdate,"+User.NORAML+","+User.USER+",null,0,0)";

		System.out.println(sql);
		PreparedStatement st=con.prepareStatement(sql);
		st.setString(1,u.getId());
		st.setString(2,u.getName());
		st.setString(3,u.getPasswd());
		st.setString(4,u.getEmail());
		st.setString(5,u.getIcon());

		int i=st.executeUpdate();
		st.close();
		if(i>0){
			return true;
		}
		return false;
	}
	
	private static User getUser(ResultSet rs) throws SQLException{
		User u=new User();
		u.setId(rs.getString("u_id"));
		u.setName(rs.getString("name"));
		u.setPasswd(rs.getString("passwd"));
		u.setStatus(rs.getInt("status"));
		u.setLastDate(rs.getString("lsd"));
		u.setRole(rs.getInt("role_id"));
		u.setForum(rs.getInt("FROUM_ID"));
		u.setScore(rs.getInt("score"));
		u.setIcon(rs.getString("icon_file"));
		if(u.getLastDate()==null || u.getLastDate().length()==0){
			u.setLastDate("新用户");
		}
		return u;
	}

	public static User getUser(Connection con,String sid) throws SQLException {
		if(con==null) return null;
		String sql="select u_id,name,passwd,status,role_id,FROUM_ID,score,icon_file,to_char(last_date,'yyyy-mm-dd hh24:mm:ss') as lsd "+
		           "from frm_user where u_id='"+sid+"'";

		System.out.println(sql);

		Statement st=con.createStatement();
		ResultSet rs=st.executeQuery(sql);
		User u=null;
		if(rs.next()){
			u=getUser(rs);
		}
		rs.close();
		st.close();
		return u;
	}

	public static void updateLastDate(Connection con,String sid)throws SQLException {
		Statement st=con.createStatement();
		st.executeQuery("update frm_user set LAST_DATE=sysdate where u_id='"+sid+"'");
		st.close();
	}

	public static boolean listUserBySQL(Connection con,String sql,Page p) throws SQLException {
		Statement st=con.createStatement();
		ResultSet rs=st.executeQuery(sql);
		ResultSetMetaData mt=rs.getMetaData();
		int cols=mt.getColumnCount();
		User u=null;
		int from=(p.getPageNo()-1)*p.getPageLen();
		int to=from+p.getPageLen();
		int total=0;
		ArrayList<User> data=new ArrayList<User>();
		while(rs.next()){
			if(total<from || total>to){
				total++;
				continue;
			}
			u=getUser(rs);
			data.add(u);		}
		p.setData(data, total, cols);
		rs.close();
		st.close();
		return true;
	}
}