daouserblog.java

java语言中servlet的用法实例

package blogServlet;
/**
 * 一版本
 */
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class DaoUserBlog {
	//加载连接数据库
	SqlConnection sqlCon = new SqlConnection();
	
	public List<UserBlog> ubList = new ArrayList();
	
	//获取用户日志：
	public List<UserBlog> getUserBlogs(String userName){
		System.out.println("Enter GetUserBlogs of DaoUserBlog:");
		String sql = "select * from userblog where userid in (select id from userinfo where name like '"+userName+"');";
		System.out.println("sql : "+sql);
		try{
			Connection conn = sqlCon.getConn();
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while(rs.next()){
				UserBlog ub = new UserBlog();
				ub.setId((int)rs.getInt(1));
				ub.setUserID((int)rs.getInt(2));
				ub.setTitle((String)rs.getString(3));
				ub.setKeyword(rs.getString(4));
				ub.setContent(rs.getString(5));
				ub.setPostTime(rs.getString(6));
				ubList.add(ub);
			}	
		}catch(Exception ex){
			ex.printStackTrace();
		}
		return ubList;
	}
	
	//新建用户日志
	public boolean newUserBlog(String name,UserBlog ui){
		System.out.println("Enter newUserBlog of DaoUserBlog:");
		try{
			java.sql.Connection conn = sqlCon.getConn();
			java.sql.Statement stmt = conn.createStatement();
			//首先获取用户ID
			String sqlGetUserID = "select id from userinfo where name like '"+name+"';";
			java.sql.ResultSet rsUserID = stmt.executeQuery(sqlGetUserID);
			
			int userID=0;
			while(rsUserID.next()){
				userID = rsUserID.getInt(1);
			}
			
			java.util.Date now = new java.util.Date();
			java.text.SimpleDateFormat f= new java.text.SimpleDateFormat("yyyy:MM:dd:hh:mm:ss");
			String post = f.format(now);
		
			String sqlNewBlog = "insert into userblog(userid,title,keyword,content,posttime) values("
					+ userID
					+ ",'"
					+ ui.getTitle()
					+ "','"
					+ ui.getKeyword()
					+ "','" + ui.getContent()
					+"','"+post
					+ "');";										
			int i = stmt.executeUpdate(sqlNewBlog);
			if(1==i){
				return true;
			}
		}catch(Exception ex){
			ex.printStackTrace();
		}
		return true;
	}
	//删除指定日志
	public boolean DelUserBlog(String blogID){
		System.out.println("Enter DelUserBlog of DaoUserBlog:");
		int id = Integer.parseInt(blogID);
		String sqlDel = "delete from userblog where id like '"+id+"';";
		try{
			java.sql.Connection conn = sqlCon.getConn();
			java.sql.Statement stmt = conn.createStatement();
			int i = stmt.executeUpdate(sqlDel);
			if(1==i)
				return true;
		}catch(Exception ex){
			ex.printStackTrace();
		}
		return false;
	}
	//修改用户日志
	public boolean modifyBlog(String sqlUpdate){
		System.out.println("Enter ModifyUserBlog of DaoUserBlog:");
		try{
			Connection conn = sqlCon.getConn();
			Statement stmt = conn.createStatement();
			int i = stmt.executeUpdate(sqlUpdate);
			if(1==i){
				return true;
			}
		}catch(Exception ex){
			ex.printStackTrace();
		}
		return false;
	}
}