JavaWeb音乐网站

package dao; import java.util.ArrayList; import vo.Special; import vo.UserFeedback; import dao.ConnectionHelpers; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.Statement; import java.sql.ResultSet; public class SpecialsDao { public ArrayList queryAllSpecials()throws Exception{ Connection con = null; Statement sta = null; ResultSet res = null; ArrayList specials = new ArrayList(); try { con = ConnectionHelpers.getMyConnection(); String sql = "SELECT * FROM Special"; sta = con.createStatement(); res = sta.executeQuery(sql); System.out.println("你有没有执行"); System.out.println(sql); while(res.next()) { Special special = new Special(); special.setSpecial_id(res.getString("specialID")); special.setSpecial_name(res.getString("specialName")); System.out.println(sql); special.setSinger_id(res.getString("singerID")); System.out.println("我感觉我真的好累啊"); special.setSpecial_language(res.getString("specialLanguage")); System.out.println("您到哪里了"); special.setSpecial_photo(res.getString("specialPhoto")); System.out.println("你执行到这里了吗"); special.setSpecial_price(res.getFloat("specialPrice")); System.out.println(sql); special.setSpecial_vote_number(res.getInt("specialVoteNumber")); System.out.println(sql); specials.add(special); } res.close(); sta.close(); } catch(Exception ex) { ex.printStackTrace(); } finally{ try{ if(con!=null){ con.close(); con=null; } }catch(Exception e){ e.printStackTrace(); } } return specials; } public int alterSpecial(ArrayList alist)//修改歌曲 { Connection con=null; Statement statement=null; int result=0; try{ con=ConnectionHelpers.getMyConnection(); for(int i=0;i<alist.size();i++){ Special special = (Special) alist.get(i); String specialPhoto = special.getSpecial_photo().trim(); String specialID = special.getSpecial_id().trim(); String specialName = special.getSpecial_name().trim(); String specialLanguage= special.getSpecial_language().trim(); float specialPrice = special.getSpecial_price(); // String specialPrice = special.getSpecialPrice(); // String specialVoteNumber = special.getSpecialVoteNumber().trim(); String sql="update Special set specialName='"+specialName+"',specialLanguage='"+specialLanguage+"',specialPhoto='"+specialPhoto+"' where specialID='"+specialID+"'"; statement = con.createStatement(); result=statement.executeUpdate(sql); System.out.println(sql);} }catch(Exception ex){ ex.printStackTrace(); } return result; } public ArrayList<Special> queryMonograph(String specialname)//用户查看专辑 { ArrayList<Special> specials=new ArrayList<Special>(); //创建一个ArrayList用来存放所有专辑信息 Connection con=null; Statement sta = null; ResultSet res = null; String sql="select * from special where specialname like '%"+specialname+"%'"; try { con=ConnectionHelpers.getMyConnection(); sta=con.createStatement(); res=sta.executeQuery(sql); while(res.next()){ Special special = new Special(); special.setSpecial_id(res.getString("specialID")); special.setSpecial_name(res.getString("specialName")); special.setSinger_id(res.getString("singerID")); special.setSpecial_language(res.getString("specialLanguage")); special.setSpecial_photo(res.getString("specialPhoto")+".jpg"); special.setSpecial_price(res.getFloat("specialPrice")); specials.add(special); } } catch(Exception ex) { ex.printStackTrace(); } return specials; } public int addSpecial(Special add_special){//添加歌曲 int add = 0; Connection con = null; PreparedStatement statement = null; try { ResultSet res = null; con=ConnectionHelpers.getMyConnection(); statement = con.prepareStatement("INSERT INTO Special " + "VALUES('"+add_special.getSpecial_id()+"','"+add_special.getSpecial_name()+"'," + "'"+add_special.getSinger_id()+"','"+add_special.getSpecial_language()+"','"+add_special.getSpecial_photo()+"'" + ",'"+add_special.getSpecial_price()+"','"+add_special.getSpecial_vote_number()+"')"); add = statement.executeUpdate(); if(add > 0) add = 1;} catch(Exception ex){ ex.printStackTrace();} try{ statement.close(); con.close();} catch(Exception ex){} return add;} //查看用户评论 public ArrayList queryAllUserFeedBack()throws Exception{ ArrayList userFeedbacks = new ArrayList(); try{ Statement sta = null; Connection con = null; ResultSet res = null; con=ConnectionHelpers.getMyConnection(); String sql = "SELECT * FROM userFeedback"; sta = con.createStatement(); res = sta.executeQuery(sql); while(res.next()) { UserFeedback userFeedback = new UserFeedback(); userFeedback.setFeedback_id(res.getInt("feedbackID")); userFeedback.setFeedback_day(res.getString("feedbackDay")); userFeedback.setUser_account(res.getString("userAccount")); userFeedback.setFeedback_content(res.getString("feedbackContent")); userFeedbacks.add(userFeedback); } } catch(Exception ex){ ex.printStackTrace(); } return userFeedbacks; } }