keyworddao.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.util.ArrayList;
import java.util.List;

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

public class KeyWordDAO extends BaseDAO{
	/**
	 * 关键词表的保存方法
	 * @param keyword
	 * @return
	 */
      public static KeyWord save(KeyWord keyword){
    	  PreparedStatement pstmt=null;
    	  String sql="insert into keyword (keyName) values (?)";
    	  try {
			pstmt=connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
					
			pstmt.setString(1,keyword.getKeyName());
			
			if(pstmt.executeUpdate()==1){
				ResultSet rs=pstmt.getGeneratedKeys();
				if(rs!=null){
					rs.next();
					keyword.setKeyId(rs.getInt(1));
				}
			}
		} catch (SQLException e) {
			
			e.printStackTrace();
		}finally{
			if(pstmt!=null){
				try {
					pstmt.close();
					pstmt=null;
				} catch (SQLException e) {					
					e.printStackTrace();
				}			
			}
		}
    	  
		return keyword;
    	  
      }
      /**
       * 关键词表的删除方法
       * @param id
       */
      public static void delete(int keyId){
    	  PreparedStatement pstmt=null;
    	  String sql="delete from keyword where keyId=?";
    	  try {
			pstmt=connection.prepareStatement(sql);
			pstmt.setInt(1, keyId);
			pstmt.executeUpdate();
			
		} catch (SQLException e) {
		
			e.printStackTrace();
		}finally{
			try {
				if(pstmt!=null){
					pstmt.close();
					pstmt=null;
				}			
			} catch (SQLException e) {				
				e.printStackTrace();
			}
		}    	  
      }
      /**
       * 关键词表 的更新方法
       * @param keyword
       */
      public static void update(KeyWord keyword){
    	  PreparedStatement pstmt=null;
    	  String sql="update keyword set keyName=? where keyId=?";
    	  try {
			pstmt=connection.prepareStatement(sql);			          
            
            pstmt.setString(1, keyword.getKeyName());
            pstmt.setInt(2,keyword.getKeyId());
			
            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 KeyWord findById(int keyId){
    	  PreparedStatement pstmt=null;
    	  ResultSet rs=null;
    	  KeyWord keyword=null;
    	  String sql="select * from keyword where keyId=?";
    	  try {
			pstmt=connection.prepareStatement(sql);
			pstmt.setInt(1, keyId);
			rs=pstmt.executeQuery();
			keyword=new KeyWord();
			while(rs.next()){				
				
				keyword.setKeyId(rs.getInt(1));
				keyword.setKeyName(rs.getString(2));
				
			}
			
		} 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 keyword;
    	  
      }
      /**
       * 关键词表 查询全部 无参数方法
       * @return
       */
      public static List<KeyWord> findAll(){
    	  PreparedStatement pstmt=null;
    	  ResultSet rs=null;
    	  List<KeyWord> rtnList=null;
    	  String sql="select * from keyword";
    	  try {
			pstmt=connection.prepareStatement(sql);
			rs=pstmt.executeQuery();
			rtnList=new ArrayList<KeyWord>();
			while(rs.next()){
				KeyWord keyword=new KeyWord();
				
				keyword.setKeyId(rs.getInt(1));
				keyword.setKeyName(rs.getString(2));
				
				rtnList.add(keyword);
			}
		} 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<KeyWord> findAll(int first,int max){
    	  PreparedStatement pstmt=null;
    	  ResultSet rs=null;
    	  List<KeyWord> rtnList=null;
    	  String sql="select * from keyword limit ?,?";
    	  try {
			pstmt=connection.prepareStatement(sql);
			pstmt.setInt(1, first);
			pstmt.setInt(2, max);
			rs=pstmt.executeQuery();
			rtnList=new ArrayList<KeyWord>();
			while(rs.next()){
				KeyWord keyword=new KeyWord();
				
				keyword.setKeyId(rs.getInt(1));
				keyword.setKeyName(rs.getString(2));
				
				rtnList.add(keyword);
			}
		} 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 KeyWord findByKeyName(String  keyName){
            PreparedStatement pstmt=null; 
    	    ResultSet rs=null;
    	    KeyWord keyword=null;
    	    String sql="select * from keyword where keyName=?";
    	    try {
				pstmt=connection.prepareStatement(sql);
				pstmt.setString(1, keyName);
				rs=pstmt.executeQuery();				
				while(rs.next()){
					keyword =new KeyWord();	
					
					keyword.setKeyId(rs.getInt(1));
					keyword.setKeyName(rs.getString(2));				
				}
				
			} catch (SQLException e) {				
				e.printStackTrace();
			}          
		return keyword;   	  
      }
     public static void main(String[] args){
    	// KeyWord keyword=new KeyWord("开心鬼2");
    	//System.out.println(KeyWordDAO.findByKeyName("开心鬼"));
     }
}