jsp实现仿QQ空间新建多个相冊名称，向相冊中加入照片
2021-06-12 02:04
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;
}
}