jsp实现仿QQ空间新建多个相冊名称,向相冊中加入照片

2021-06-12 02:04

阅读:453

public class UpDAOImpl implements UpDAO {

	/* (non-Javadoc)
	 * @see cn.jvsun.DAO.UpDAO#creAlbum(cn.jvsun.POJO.AlbumPOJO)
	 * 创建相冊名称
	 */
	public int creAlbum(AlbumPOJO ap) {
		int albumNum=this.getAlbumNum();
		Connection conn = null;
		PreparedStatement pstate = null;
		try {
			conn=JDBCHelper.getConn();
			conn.setAutoCommit(false);
			String sql="insert into album(id,a_name,user_id)values(?,?

,?)"; pstate = conn.prepareStatement(sql); pstate.setInt(1, albumNum); pstate.setString(2,ap.getA_name()); pstate.setInt(3, ap.getUser_id()); pstate.execute(); conn.commit(); } catch (Exception e) { e.printStackTrace(); try { conn.rollback();//出问题就撤回,全不提交 } catch (SQLException e1) { e1.printStackTrace(); } }finally{ try { pstate.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } return albumNum; } /* (non-Javadoc) * @see cn.jvsun.DAO.UpDAO#upPhoto(java.lang.String, java.lang.String, int) * 上传照片 */ public int upPhoto(PhotoPOJO pp) { int pNum=this.getPhotoNum(); Connection conn = null; PreparedStatement pstate = null; try { conn=JDBCHelper.getConn(); conn.setAutoCommit(false); String sql="insert into photo(id,p_name,p_url,p_albumid)values(?,?,?,?)"; pstate = conn.prepareStatement(sql); pstate.setInt(1, pNum); pstate.setString(2,pp.getP_name()); pstate.setString(3, pp.getP_url()); pstate.setInt(4, pp.getP_albumId()); pstate.execute(); conn.commit(); } catch (Exception e) { e.printStackTrace(); try { conn.rollback();//出问题就撤回,全不提交 } catch (SQLException e1) { e1.printStackTrace(); } }finally{ try { pstate.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } return pNum; } /* (non-Javadoc) * @see cn.jvsun.DAO.UpDAO#delAlbum(int) * 删除相冊 */ public int delAlbum(int id) { int result=0; Connection conn = null; PreparedStatement pstate = null; String sql="delete from album where id="+id+""; try { conn=JDBCHelper.getConn(); pstate = conn.prepareStatement(sql); result=pstate.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ try { pstate.close(); conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } return result; } /* (non-Javadoc) * @see cn.jvsun.DAO.UpDAO#delPhoto(int) * 删除照片 */ public int delPhoto(int id) { int result=0; Connection conn = null; PreparedStatement pstate = null; String sql="delete from photo where id="+id+""; try { conn=JDBCHelper.getConn(); pstate = conn.prepareStatement(sql); result=pstate.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ try { pstate.close(); conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } return result; } /* (non-Javadoc) * @see cn.jvsun.DAO.UpDAO#login(java.lang.String, java.lang.String) * 用户登录 */ public UserPOJO login(String username, String password) { UserPOJO user=null; Connection conn = null; PreparedStatement pstate = null; ResultSet res = null; try { conn=JDBCHelper.getConn(); String sql="select id,username from userinfo where username=? and password=?"; pstate = conn.prepareStatement(sql); pstate.setString(1, username); pstate.setString(2, password); res = pstate.executeQuery(); while(res.next()){ user=new UserPOJO(res.getInt(1),username,null); } } catch (Exception e) { e.printStackTrace(); }finally{ try { res.close(); pstate.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } return user; } /** * 相冊序列号 */ public int getAlbumNum(){ int albumNum=-1; Connection conn = null; PreparedStatement pstate = null; ResultSet res = null; try { conn=JDBCHelper.getConn(); String sql="select aid.nextval from dual"; pstate=conn.prepareStatement(sql); res=pstate.executeQuery(); while(res.next()){ albumNum=res.getInt(1); } } catch (Exception e) { e.printStackTrace(); }finally{ try { res.close(); pstate.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } return albumNum; } /** *照片序列号 */ public int getPhotoNum(){ int photoNum=-1; Connection conn = null; PreparedStatement pstate = null; ResultSet res = null; try { conn=JDBCHelper.getConn(); String sql="select pid.nextval from dual"; pstate=conn.prepareStatement(sql); res=pstate.executeQuery(); while(res.next()){ photoNum=res.getInt(1); } } catch (Exception e) { e.printStackTrace(); }finally{ try { res.close(); pstate.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } return photoNum; } /* (non-Javadoc) * @see cn.jvsun.DAO.UpDAO#findAll() * 显示所创建的相冊名 */ public List findAllAlbum(int id) { List list= new ArrayList(); Connection conn = null; PreparedStatement pstate = null; ResultSet res = null; try { conn=JDBCHelper.getConn(); String sql="select id,a_name,user_id from album where user_id=?"; pstate = conn.prepareStatement(sql); pstate.setInt(1, id); res = pstate.executeQuery(); while(res.next()){ AlbumPOJO ap=new AlbumPOJO(res.getInt(1),res.getString(2),res.getInt(3)); list.add(ap); } } catch (Exception e) { e.printStackTrace(); }finally{ try { res.close(); pstate.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } return list; } /* (non-Javadoc) * @see cn.jvsun.DAO.UpDAO#findAllPhoto(int) * 显示照片 */ public List findAllPhoto(int aid) { List list= new ArrayList(); Connection conn = null; PreparedStatement pstate = null; ResultSet res = null; try { conn=JDBCHelper.getConn(); String sql="select id,p_name,p_url from photo where P_ALBUMID=?"; pstate = conn.prepareStatement(sql); pstate.setInt(1, aid); res = pstate.executeQuery(); while(res.next()){ PhotoPOJO pojo=new PhotoPOJO(res.getInt(1),res.getString(2),res.getString(3), aid); list.add(pojo); } } catch (Exception e) { e.printStackTrace(); }finally{ try { res.close(); pstate.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } return list; } }


评论


亲,登录后才可以留言!