dbquery.java

只是个JAVA 的小程序~是关于添加书本子类的程序

/*
 * DBQuery.java
 *
 * Created on 2007年10月29日, 上午8:32
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package addressBook;

/**
 *
 * @author Administrator
 */
import java.sql.*;
import java.util.*;
class DBQuery {
    private Statement sta;//用于数据库操作的Statement
    People people;
    Person person;
    /** Creates a new instance of DbQuery */
    public DBQuery() {
    }
    public ArrayList getPeople(){
        String name;
        String yzbm;
        String txdz;
        String dh;
        String celephone;
        String email;
        ArrayList list=new ArrayList(); 
        try{
            DbConnect driver= new DbConnect();
            DBQuery query=new DBQuery();
                      
            ResultSet rs;  //结果集
            String sqlCommand;  //用于操作的SQL命令
            driver.setURL("jdbc:odbc:txl");
            driver.setUser("");
            driver.setPassword("");
            Connection con=driver.getConnection();
            //设置Statement查询操作
            query.setStatement(con);
            sqlCommand="Select * from txl";
            System.out.println("\n# # # # # # # # # 查询操作# # # # # # # # #");
            System.out.println("输入SQL命令"+sqlCommand+"\n");
            rs=query.executeQuery(sqlCommand);
            rs.next();
            System.out.println("姓名  "+"邮政编码  "+"通信地址  "+"电话  "+"手机"+"电子邮件   ");
            //循环输出结果集的内容
            for(int i=0;i<rs.getRow();i++){
                name=rs.getString("姓名");
                yzbm=rs.getString("邮政编码");
                txdz=rs.getString("通信地址");
                dh=rs.getString("电话");
                celephone=rs.getString("手机");
                email=rs.getString("电子邮件");
                person=new Person(name,yzbm,txdz,dh,celephone,email);
                list.add(person);
                rs.next();//定位下一行
            }
            //关闭所有连接,释放资源
            rs.close();
            query.closeStatement();
            con.close();
           
        }catch(Exception e){
            System.out.println(e.toString());
        }finally{
             return list;
        }
    }
    public void savePeople(Person person,String oldName){
        String name=person.getName();
        String yzbm=person.getZip();
        String txdz=person.getAddress();
        String dh=person.getTelephone();
        String celephone=person.getCellphone();
        String email=person.getEmail();
        try{
            DbConnect driver= new DbConnect();
            DBQuery query=new DBQuery();                     
            int result ;  //结果集
            StringBuffer sqlCommand=new StringBuffer();  //用于操作的SQL命令
            driver.setURL("jdbc:odbc:txl");
            driver.setUser("");
            driver.setPassword("");
            Connection con=driver.getConnection();
            //设置Statement查询操作
            query.setStatement(con);
            sqlCommand.append("update txl set 姓名='"+name+"',邮政编码='"+yzbm+"',通信地址='" +
                    txdz+"',电话='"+dh+"',手机='"+celephone+"',电子邮件='"+email+"' where 姓名='"+oldName+"'");
            System.out.println("\n# # # # # # # # # 修改操作# # # # # # # # #");
            System.out.println("输入SQL命令"+sqlCommand+"\n");
            result=query.executeUpdate(sqlCommand.toString());
         
            query.closeStatement();
            con.close();
           
        }catch(Exception e){
            System.out.println(e.toString());
        }finally{
            
        }
    }
    
    public void addPeople(Person person){
        String name=person.getName();
        String yzbm=person.getZip();
        String txdz=person.getAddress();
        String dh=person.getTelephone();
        String celephone=person.getCellphone();
        String email=person.getEmail();
        try{
            DbConnect driver= new DbConnect();
            DBQuery query=new DBQuery();                     
            int result ;  //结果集
            StringBuffer sqlCommand=new StringBuffer();  //用于操作的SQL命令
            driver.setURL("jdbc:odbc:txl");
            driver.setUser("");
            driver.setPassword("");
            Connection con=driver.getConnection();
            //设置Statement查询操作
            query.setStatement(con);
            sqlCommand.append("insert into txl(姓名,邮政编码,通信地址,电话,手机,电子邮件) values('"+name+"','"
                    +yzbm+"','"+txdz+"','"+dh+"','"+celephone+"','"+email+"')");
            System.out.println("\n# # # # # # # # # 插入操作# # # # # # # # #");
            System.out.println("输入SQL命令"+sqlCommand+"\n");
            result=query.executeUpdate(sqlCommand.toString());
         
            query.closeStatement();
            con.close();
           
        }catch(Exception e){
            System.out.println(e.toString());
        }finally{
            
        }
    }
      public void deletePeople(String name){
              
        try{
            DbConnect driver= new DbConnect();
            DBQuery query=new DBQuery();                     
            int result ;  //结果集
            StringBuffer sqlCommand=new StringBuffer();  //用于操作的SQL命令
            driver.setURL("jdbc:odbc:txl");
            driver.setUser("");
            driver.setPassword("");
            Connection con=driver.getConnection();
            //设置Statement查询操作
            query.setStatement(con);
            sqlCommand.append("delete from txl where 姓名='"+name+"'");
            System.out.println("\n# # # # # # # # # 删除操作# # # # # # # # #");
            System.out.println("输入SQL命令"+sqlCommand+"\n");
            result=query.executeUpdate(sqlCommand.toString());
         
            query.closeStatement();
            con.close();
           
        }catch(Exception e){
            System.out.println(e.toString());
        }finally{
            
        }
    }
    public void setStatement(Connection con){
        try{
            //Statement中有关查询数据库的方法
            this.sta=con.createStatement();
        }catch(Exception e){
            System.out.println(e.toString());
        }
    }
    public ResultSet executeQuery(String sqlCommand){
        try{
            //Statement中有关修改数据库的方法
            return sta.executeQuery(sqlCommand);
        }catch(Exception e){
            System.out.println(e.toString());
        }
        return null;
    }
       
    public int executeUpdate(String sqlCommand){
        try{
            //Statement中有关修改数据库的方法
            return sta.executeUpdate(sqlCommand);
        }catch(Exception e){
            System.out.println(e.toString());
        }
     return -1;
    }
    public void closeStatement(){
        try{
            sta.close();
        }catch(Exception e){
            System.out.println(e.toString());
        }
    }
}