albuminfodao.java

模拟的土豆网视频网站

package cn.myvideosite.data.model.dao;

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

import cn.myvideosite.data.model.bean.AlbumInfo;

public class AlbumInfoDAO extends BaseDAO{
	   /**
	    * 专辑信息表保存方法
	    * @param albuminfo
	    * @return
	    */
       public static AlbumInfo save(AlbumInfo albuminfo){
    	   PreparedStatement pstmt=null;
    	   String sql="insert into albuminfo(userId,albumTitle,albumIntro,albumAddr,videoNub,popular,createTime ,imageUrl,flashUrl,albumTypeId) values (?,?,?,?,?,?,?,?,?,?)";
    	   try {
			pstmt=connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
					
			pstmt.setInt(1,albuminfo.getUserId());
			pstmt.setString(2,albuminfo.getAlbumTitle());
			pstmt.setString(3,albuminfo.getAlbumIntro());			
			pstmt.setString(4,albuminfo.getAlbumAddr());
			pstmt.setInt(5, albuminfo.getVideoNub());
			pstmt.setInt(6, albuminfo.getPopular());
			pstmt.setTimestamp(7,new Timestamp(albuminfo.getCreateTime().getTime()));
			pstmt.setString(8,albuminfo.getImageUrl());
			pstmt.setString(9,albuminfo.getFlashUrl());
			pstmt.setInt(10, albuminfo.getAlbumTypeId());
			
			if(pstmt.executeUpdate()==1){
				ResultSet rs=pstmt.getGeneratedKeys();
				if(rs!=null){
					rs.next();
					albuminfo.setAlbumId(rs.getInt(1));
				}
			}
		} catch (SQLException e) {
			
			e.printStackTrace();
		}finally{
			if(pstmt!=null){
				try {
					pstmt.close();
					pstmt=null;
				} catch (SQLException e) {
					
					e.printStackTrace();
				}
			
			}
		}
    	   
    	   return albuminfo;
       }
       /**
        * 专辑信息表删除方法
        * @param id
        * @return
        */
       public static void delete(int albumId){
    	   PreparedStatement pstmt=null;
    	   String sql="delete from albuminfo where albumId=?";
    	   try {
			 pstmt=connection.prepareStatement(sql);
			 pstmt.setInt(1, albumId);
	    	 pstmt.executeUpdate();
		} catch (SQLException e) {			
			e.printStackTrace();
		}finally{
			try {
				if(pstmt!=null){
					pstmt.close();
					pstmt=null;
				}			
			} catch (SQLException e) {				
				e.printStackTrace();
			}
		}    	  		 
       }
       /**
        * 专辑信息表更新方法
        * @param albuminfo
        * @return
        */
       public static void update(AlbumInfo albuminfo){
    	 PreparedStatement pstmt=null;
    	 String sql="update albuminfo set userId=?,albumTitle=?,albumIntro=?,albumAddr=?,videoNub=?,popular=?,createTime=?,imageUrl=?,flashUrl=? where albumId=?";
    	 try {
			pstmt=connection.prepareStatement(sql);
									
			pstmt.setInt(1,albuminfo.getUserId());
			pstmt.setString(2,albuminfo.getAlbumTitle());
			pstmt.setString(3,albuminfo.getAlbumIntro());			
			pstmt.setString(4,albuminfo.getAlbumAddr());
			pstmt.setInt(5, albuminfo.getVideoNub());
			pstmt.setInt(6, albuminfo.getPopular());
			pstmt.setTimestamp(7,new Timestamp(albuminfo.getCreateTime().getTime()));
			pstmt.setInt(8, albuminfo.getAlbumId());
			pstmt.setString(9,albuminfo.getImageUrl());
			pstmt.setString(10,albuminfo.getFlashUrl());
			pstmt.setInt(11, albuminfo.getAlbumTypeId());
			
			pstmt.executeUpdate();
		} catch (SQLException e) {
			
			e.printStackTrace();
		}finally{
			try {
				if(pstmt!=null){
				pstmt.close();
				pstmt=null;
				}
			} catch (SQLException e) {
				
				e.printStackTrace();
			}
		}		  	   
       }
       /**
        * 专辑信息表查找方法 单条记录
        * @param id
        * @return
        */
       public static AlbumInfo findById(int albumId){
    	   PreparedStatement pstmt=null;
    	   ResultSet rs=null;   	  
    	   AlbumInfo albuminfo=null;
    	   String sql="select * from albuminfo where albumId=?";
    	   try {
			pstmt=connection.prepareStatement(sql);
			pstmt.setInt(1,albumId);
			rs=pstmt.executeQuery();
			albuminfo=new AlbumInfo();
			while(rs.next()){
				
				albuminfo.setAlbumId(rs.getInt(1));
				albuminfo.setUserId(rs.getInt(2));
				albuminfo.setAlbumTitle(rs.getString(3));
				albuminfo.setAlbumIntro(rs.getString(4));
				albuminfo.setAlbumAddr(rs.getString(5));
				albuminfo.setVideoNub(rs.getInt(6));
				albuminfo.setPopular(rs.getInt(7));
				albuminfo.setCreateTime(rs.getTimestamp(8));
				albuminfo.setImageUrl(rs.getString(9));
				albuminfo.setFlashUrl(rs.getString(10));
				albuminfo.setAlbumTypeId(rs.getInt(11));
			}
		} catch (SQLException e) {
			
			e.printStackTrace();
		} finally{
			try {
				if(rs!=null){
				rs.close();
				rs=null;
				}
				if(pstmt!=null){
				pstmt.close();
				pstmt=null;
				}
			} catch (SQLException e) {
				
				e.printStackTrace();
			}
		}
		return albuminfo;   	   
       }
       /**
        * 专辑信息表查询全部 无参数方法
        * @return
        */
       public static List<AlbumInfo> findAll(){
    	   PreparedStatement pstmt=null;
    	   ResultSet rs=null;
    	   List<AlbumInfo> rtnList=null;
    	   String sql="select * from albuminfo";
    	   try {
			pstmt=connection.prepareStatement(sql);
			rs=pstmt.executeQuery();
			rtnList=new ArrayList<AlbumInfo>();
			while(rs.next()){
				AlbumInfo albuminfo=new AlbumInfo();
				
				albuminfo.setAlbumId(rs.getInt(1));
				albuminfo.setUserId(rs.getInt(2));
				albuminfo.setAlbumTitle(rs.getString(3));
				albuminfo.setAlbumIntro(rs.getString(4));
				albuminfo.setAlbumAddr(rs.getString(5));
				albuminfo.setVideoNub(rs.getInt(6));
				albuminfo.setPopular(rs.getInt(7));
				albuminfo.setCreateTime(rs.getTimestamp(8));
				albuminfo.setImageUrl(rs.getString(9));
				albuminfo.setFlashUrl(rs.getString(10));
				albuminfo.setAlbumTypeId(rs.getInt(11));
				
				rtnList.add(albuminfo);			
			}
			
		} catch (SQLException e) {
			
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
				rs.close();
				rs=null;
				}
				if(pstmt!=null){
				pstmt.close();
				pstmt=null;
				}
			} catch (SQLException e) {
				
				e.printStackTrace();
			}
		}    	   
   		return rtnList;      	   
    }
       /**
        * 专辑信息表 查询全部 有参数方法
        * @param first
        * @param max
        * @return
        */
       public static List<AlbumInfo> findAll(int first,int max){
    	   PreparedStatement pstmt=null;
    	   ResultSet rs=null;
    	   List<AlbumInfo> rtnList=null;
    	   String sql="select * from albuminfo limit ?,?";
    	   try {
			pstmt=connection.prepareStatement(sql);
			pstmt.setInt(1,first);
			pstmt.setInt(2, max);
			rs=pstmt.executeQuery();
			rtnList=new ArrayList<AlbumInfo>();
			while(rs.next()){
				AlbumInfo albuminfo=new AlbumInfo();
				
				albuminfo.setAlbumId(rs.getInt(1));
				albuminfo.setUserId(rs.getInt(2));
				albuminfo.setAlbumTitle(rs.getString(3));
				albuminfo.setAlbumIntro(rs.getString(4));
				albuminfo.setAlbumAddr(rs.getString(5));
				albuminfo.setVideoNub(rs.getInt(6));
				albuminfo.setPopular(rs.getInt(7));
				albuminfo.setCreateTime(rs.getTimestamp(8));
				albuminfo.setImageUrl(rs.getString(9));
				albuminfo.setFlashUrl(rs.getString(10));
				albuminfo.setAlbumTypeId(rs.getInt(11));
				
				rtnList.add(albuminfo);																
			}									
		} catch (SQLException e) {
			
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
				rs.close();
				rs=null;
				}
				if(pstmt!=null){
				pstmt.close();
				pstmt=null;
				}
			} catch (SQLException e) {
				
				e.printStackTrace();
			}
		}  	   
		return rtnList;   	   
       }
       public static void main(String[] args){
    	   System.out.println(findAll(0,10));
       }
       /**
        *  查找专辑信息地址唯一行的方法
        */
       public static AlbumInfo findByAlbumAddr(String  albumAddr){
    	   PreparedStatement pstmt=null;
    	   ResultSet rs=null;   	  
    	   AlbumInfo albuminfo=null;
    	   String sql="select * from albuminfo where albumAddr=?";
    	   try {
			pstmt=connection.prepareStatement(sql);
			pstmt.setString(1,albumAddr);
			rs=pstmt.executeQuery();
			if(rs.next()){
				albuminfo=new AlbumInfo();
				
				albuminfo.setAlbumId(rs.getInt(1));
				albuminfo.setUserId(rs.getInt(2));
				albuminfo.setAlbumTitle(rs.getString(3));
				albuminfo.setAlbumIntro(rs.getString(4));
				albuminfo.setAlbumAddr(rs.getString(5));
				albuminfo.setVideoNub(rs.getInt(6));
				albuminfo.setPopular(rs.getInt(7));
				albuminfo.setCreateTime(rs.getTimestamp(8));
				albuminfo.setImageUrl(rs.getString(9));
				albuminfo.setFlashUrl(rs.getString(10));
				albuminfo.setAlbumTypeId(rs.getInt(11));
			}
		} catch (SQLException e) {			
			e.printStackTrace();
		} finally{
			try {
				if(rs!=null){
				rs.close();
				rs=null;
				}
				if(pstmt!=null){
				pstmt.close();
				pstmt=null;
				}
			} catch (SQLException e) {
				
				e.printStackTrace();
			}
		}  	    	   
		  return albuminfo;   	   
       }     
}