package dao.Impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.*;
import dao.BaseDao;
import dao.IPetDao;
import entity.Pet;
/**
* 宠物实现类
* @author Administrator
*
*/
public class PetDaoImpl extends BaseDao implements IPetDao{
private Connection conn=null;
private ResultSet rs=null;
private PreparedStatement ps=null;
List list =new ArrayList();
int num=0;
/**
* 按Id删除
*/
public int deletePetId(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="delete from pet where petId=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("删除了id为:"+pet.getPetId()+"的宠物的一行数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("删除宠物发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
/**
* 新增
*/
public int insertPet(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="insert into pet(petname,petsex,petage,pettype,petimage,ownid,petnote) values(?,?,?,?,?,?,?)";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, pet.getPetName());
ps.setString(2, pet.getSex());
ps.setString(3, Integer.toString(pet.getAge()));
ps.setString(4, pet.getType());
ps.setString(5, pet.getImage());
ps.setString(6, Integer.toString(pet.getOwnId()));
ps.setString(7, pet.getPetNote());
num=ps.executeUpdate();
System.out.println("新增了名为:"+pet.getPetName()+"的宠物");
} catch (Exception e) {
// TODO: handle exception
System.out.println("新增宠物发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
/**
* 查询
*/
public int getPet(){
try {
String sql="select count(*) from pet";
conn=super.getConn();
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
while(rs.next()){
num=rs.getInt(1);
}
} catch (Exception e) {
// TODO: handle exception
e.getMessage();
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public List selectPet(int page) {
// TODO Auto-generated method stub
try {
int rowBegin=0;
if(page>1){
rowBegin=3*(page-1);
}
String sql="select top 3 * from pet where petId not in (select top "+rowBegin+" petid from pet)";
conn=super.getConn();
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
while(rs.next()){
Pet p=new Pet();
p.setPetId(rs.getInt(1));
p.setPetName(rs.getString(2));
p.setSex(rs.getString(3));
p.setAge(rs.getInt(4));
p.setType(rs.getString(5));
p.setImage(rs.getString(6));
p.setOwnId(rs.getInt(7));
p.setPetNote(rs.getString(8));
list.add(p);
}
} catch (Exception e) {
// TODO: handle exception
System.out.println("查询宠物数据发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return list;
}
/**
* 更新
*/
public int updatePetImage(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="update pet set petimage=? where petid=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, pet.getImage());
ps.setString(2, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("更新了id为:"+pet.getPetId()+"的一行宠物数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("更新宠物Id发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public int updatePetName(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="update pet set petname=? where petid=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, pet.getPetName());
ps.setString(2, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("更新了id为:"+pet.getPetId()+"的一行宠物数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("更新宠物Id发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public int updatePetNote(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="update pet set petnote=? where petid=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, pet.getPetNote());
ps.setString(2, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("更新了id为:"+pet.getPetId()+"的一行宠物数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("更新宠物Id发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public int updatePetOwnId(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="update pet set ownid=? where petid=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, Integer.toString(pet.getOwnId()));
ps.setString(2, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("更新了id为:"+pet.getPetId()+"的一行宠物数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("更新宠物Id发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public int updatePetSex(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="update pet set petSex=? where petid=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, pet.getSex());
ps.setString(2, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("更新了id为:"+pet.getPetId()+"的一行宠物数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("更新宠物Id发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public int updatePetType(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="update pet set petType=? where petid=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, pet.getType());
ps.setString(2, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("更新了id为:"+pet.getPetId()+"的一行宠物数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("更新宠物Id发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public int updatePetAge(Pet pet) {
// TODO Auto-generated method stub
try {
String sql="update pet set petAge=? where petid=?";
conn=super.getConn();
ps=conn.prepareStatement(sql);
ps.setString(1, Integer.toString(pet.getAge()));
ps.setString(2, Integer.toString(pet.getPetId()));
num=ps.executeUpdate();
System.out.println("更新了id为:"+pet.getPetId()+"的一行宠物数据!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("更新宠物Id发生异常:"+e.getMessage());
}finally{
super.closeAll(rs, ps, conn);
}
return num;
}
public static void main(String[] args) {
Pet p=new Pet();
// p.setPetId(39);
// new PetDaoImpl().deletePet(p);
// p.setPetId(39);
// p.setPetName("恐龙");
// p.setSex("雄");
// p.setAge(3);
// p.setType("动物");
// p.setImage("dd");
// p.setOwnId(3);
// p.setPetNote("dsfsdfsdfsdf");
// new PetDaoImpl().insertPet(p);
// List list=new PetDaoImpl().selectPet(1);
// for(int i=0;i<list.size();i++){
// Pet pet=(Pet)list.get(i);
// System.out.println(pet.getPetName());
}
}