【Java开源代码栏目提醒】:网学会员在Java开源代码频道为大家收集整理了VoteDaoImpl.java提供大家参考,希望对大家有所帮助!
package com.victor.dao;
import java.util.List;
import com.victor.tool.JDBConnection;
import com.victor.domain.VoteActionForm;
import java.sql.ResultSet;
import java.sql.*;
import java.util.ArrayList;
//查看投票的人物的信息
public class VoteDaoImpl
implements VoteDao {
public List selectVote() {
List list = new ArrayList();
JDBConnection connection = new JDBConnection();
VoteActionForm vote = null;
String sql = "select * from tb_Vote";
ResultSet rs = connection.executeQuery(sql);
try {
while (rs.next()) {
vote = new VoteActionForm();
vote.setID(Integer.valueOf(rs.getString(1)));
vote.setName(rs.getString(2));
vote.setAddress(rs.getString(3));
vote.setCountry(rs.getString(4));
vote.setJop(rs.getString(5));
vote.setRemark(rs.getString(6));
vote.setNumber(Integer.valueOf(rs.getString(7)));
list.add(vote);
}
}
catch (SQLException ex) {
}
connection.close();
return list;
}
//对新闻人物的添加
public void insertVote(VoteActionForm vote) {
JDBConnection connection = new JDBConnection();
String sql = "insert into tb_vote values('" +
vote.getName() + "','" + vote.getAddress() + "','" + vote.getCountry() +
"','" + vote.getJop() + "','" + vote.getRemark() + "',0)";
connection.executeUpdate(sql);
connection.close();
}
//对新闻人物的删除
public void deleteVote(VoteActionForm vote) {
JDBConnection connection = new JDBConnection();
String sql = "delete from tb_vote where ID='" + vote.getID() + "'";
connection.executeUpdate(
sql);
connection.close();
}
//对新闻的单独查找
public List selectOneVote(VoteActionForm vote) {
List list = new ArrayList();
JDBConnection connection = new JDBConnection();
VoteActionForm voteActionForm = null;
String sql = "select * from tb_Vote where ID='" + vote.getID() +
"'";
ResultSet rs = connection.executeQuery(sql);
try {
while (rs.next()) {
voteActionForm = new VoteActionForm();
voteActionForm.setID(Integer.valueOf(rs.getString(1)));
voteActionForm.setName(rs.getString(2));
voteActionForm.setAddress(rs.getString(3));
voteActionForm.setCountry(rs.getString(4));
voteActionForm.setJop(rs.getString(5));
voteActionForm.setRemark(rs.getString(6));
voteActionForm.setNumber(Integer.valueOf(rs.getString(7)));
list.add(voteActionForm);
}
}
catch (SQLException ex) {
}
connection.close();
return list;
}
//对新闻人物的修改
public void updateVote(VoteActionForm vote) {
JDBConnection connection = new JDBConnection();
String sql ="update tb_vote set Name='"+vote.getName()+"',Address='"+vote.getAddress()+"',Country='"+vote.getCountry()+"',Job='"+vote.getJop()+"',Remark='"+vote.getRemark()+"' where ID='"+vote.getID()+"'";
connection.executeUpdate(sql);
connection.close();
}
//对新闻人物的投票操作
public void addVote(VoteActionForm vote) {
JDBConnection connection=new JDBConnection();
String sql="update tb_vote set Number=Number+1 where ID='"+vote.getID()+"'";
connection.executeUpdate(sql);
connection.close();
}
}