motherboardsdao.java~53~

些程序用java实现一个装机程序,不过是一个C/S架构,但是在数据库的设计方面与3层架构的构造方案我想对一些朋友还是否有一定的帮助吧

package pcdiysystem.Dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Vector;
import pcdiysystem.Beans.MotherboardsBean;
import javax.swing.JOptionPane;
import pcdiysystem.Panel.EditPanel;
import javax.swing.table.TableModel;

/**
 * <p>Title: 自助装机系统</p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author kamiiiyu
 * @version 1.0
 */
public class MotherboardsDAO {

  public static final int COMPONENTLISTPANEL=0;
  public static final int EDITPANEL=1;
  private EditPanel epObj;

  public MotherboardsDAO() {

  }

  public MotherboardsDAO(EditPanel epObj) {
    this.epObj=epObj;
  }

  public Vector getBaseInfomation(String manufacturer,int panel){
    Vector list=new Vector();
    Connection dbConnection=null;
    PreparedStatement pStatement=null;
    ResultSet resultSet=null;
    try {
      dbConnection = ConnectionManager.getConnection();
      if(dbConnection!=null)
        System.out.println("OK!");
      String proList = "select p.* from motherboards as p left outer join Manufacturersofmotherboard as ma on ma.Manufacturerid=p.manufacturerid where ma.manufacturer=?";
      pStatement = dbConnection.prepareStatement(proList);
      pStatement.setString(1, manufacturer);
      resultSet=pStatement.executeQuery();
        while (resultSet.next()) {
          MotherboardsBean pb = new MotherboardsBean();
          switch(panel){
            case 0:break;
            case 1: pb.setRecord(resultSet.getString(1));
          }
          pb.setRecord(resultSet.getString(3));
          pb.setRecord(resultSet.getString(4));
          pb.setRecord(resultSet.getString(5));
          pb.setRecord(resultSet.getString(6));
          pb.setRecord(resultSet.getString(7));
          switch(panel){
            case 0:break;
            case 1:pb.setRecord(resultSet.getString(8));
          }
          pb.setRecord(resultSet.getString(9));
          pb.setRecord(resultSet.getString(10));
          list.add(pb.getRecord());
        }
    }
    catch (SQLException ex) {
    }finally{
      ConnectionManager.closeResultSet(resultSet);
      ConnectionManager.closeStatement(pStatement);
      ConnectionManager.closeConnection(dbConnection);
    }
    return list;
  }

  public boolean updateRecord(int recordId,Vector updateData){
    Vector list=new Vector();
    Connection dbConnection=null;
    PreparedStatement pStatement=null;
    ResultSet resultSet=null;
    try {
      dbConnection = ConnectionManager.getConnection();
      if(dbConnection!=null)
        System.out.println("OK!");
      String ps = "update motherboards set type=?,socket=?,chipset=?,compatiblecpu=?,videointerface=?,description=?,storage=?,price=? where id=?";
      pStatement = dbConnection.prepareStatement(ps);
      int temp=updateData.size();
      for(int i=0;i<temp;i++){
        pStatement.setString(i+1, String.valueOf(updateData.get(i)));
      }
      pStatement.setInt(temp+1,recordId);
      int rowCount=pStatement.executeUpdate();
      return true;
    }
    catch (SQLException ex) {
      System.out.println("uerr");
      return false;
    }finally{
      ConnectionManager.closeResultSet(resultSet);
      ConnectionManager.closeStatement(pStatement);
      ConnectionManager.closeConnection(dbConnection);
    }
  }

  public boolean deleteRecord(int recordId){
    Vector list=new Vector();
    Connection dbConnection=null;
    PreparedStatement pStatement=null;
    ResultSet resultSet=null;
    try {
      dbConnection = ConnectionManager.getConnection();
      if(dbConnection!=null)
        System.out.println("OK!");
      String ps = "delete from motherboards where id=?";
      pStatement = dbConnection.prepareStatement(ps);
      pStatement.setInt(1,recordId);
      int rowCount=pStatement.executeUpdate();
      return true;
    }
    catch (SQLException ex) {
      System.out.println("derr");
      return false;
    }finally{
      ConnectionManager.closeResultSet(resultSet);
      ConnectionManager.closeStatement(pStatement);
      ConnectionManager.closeConnection(dbConnection);
    }
  }

  public boolean insertFile(String manufacturerId,Vector insertData){
    Connection dbConnection=null;
    PreparedStatement pStatement=null;
    ResultSet resultSet=null;
    try {
      dbConnection = ConnectionManager.getConnection();
      if(dbConnection!=null)
        System.out.println("OK!");
      String ps = "insert into motherboards(manufacturerId,type,socket,chipset,compatiblecpu,videointerface,[description],storage,price)values(?,?,?,?,?,?,?,?,?)";
      MotherboardsBean mb=new MotherboardsBean();
      mb.setDataOfTable(insertData);
      for(int i=0;i<mb.getDataOfTable().size();i++){
        pStatement = dbConnection.prepareStatement(ps);
        pStatement.setString(1,manufacturerId);
        for(int j=0;j<((Vector)mb.getDataOfTable().get(i)).size();j++){
          pStatement.setString(j+2,String.valueOf(((Vector)mb.getDataOfTable().get(i)).get(j)));
        }
        int rowCount=pStatement.executeUpdate();
        pStatement=null;
      }
      return true;
    }
    catch (SQLException ex) {
      System.out.println("ferr");
      return false;
    }finally{
      ConnectionManager.closeResultSet(resultSet);
      ConnectionManager.closeStatement(pStatement);
      ConnectionManager.closeConnection(dbConnection);
    }
  }

  public Vector getDataFromTableMOdel(TableModel dtm){
    MotherboardsBean mb=new MotherboardsBean();
    int rowCount=dtm.getRowCount();
    int columnCount=dtm.getColumnCount();
    for(int i=0;i<rowCount;i++){
      Vector tdTemp=new Vector();
      for(int j=1;j<columnCount;j++){
        Object td=dtm.getValueAt(i,j);
        tdTemp.add(td);
      }
      mb.setFile(tdTemp);
    }
    return mb.getFile();
  }

  public boolean isPriceFormatCorrect(String price){
    MotherboardsBean mb=new MotherboardsBean();
    mb.setPrice(price);
    if(!mb.getPrice().startsWith("￥")){
      JOptionPane.showMessageDialog(epObj,"请以“￥”为首字符输入价格","非法输入！",JOptionPane.ERROR_MESSAGE);
      return false;
    }else{
      String main = mb.getPrice().substring(1);
      try {
        float num = Float.parseFloat(main);
      }
      catch (NumberFormatException nfe) {
        JOptionPane.showMessageDialog(epObj, "符号“￥”后面只允许输入数字！","非法输入！",JOptionPane.ERROR_MESSAGE);
        return false;
      }
    }
    return true;
  }

  public Vector getDataInblurQuery(String keyword){
    keyword="%"+keyword+"%";
    Connection dbConnection=null;
    PreparedStatement pStatement=null;
    ResultSet resultSet=null;
    try {
      dbConnection = ConnectionManager.getConnection();
      if(dbConnection!=null)
        System.out.println("OK!");
      String proList = "select * from motherboards where [description] like ?";
      pStatement = dbConnection.prepareStatement(proList);
      pStatement.setString(1, keyword);
      resultSet=pStatement.executeQuery();
      MotherboardsBean mb=new MotherboardsBean();
      while (resultSet.next()) {
        MotherboardsBean pb = new MotherboardsBean();
        //pb.setRecord(resultSet.getString(1));
        //pb.setRecord(resultSet.getString(2));
        pb.setRecord(resultSet.getString(3));
        pb.setRecord(resultSet.getString(4));
        pb.setRecord(resultSet.getString(5));
        pb.setRecord(resultSet.getString(6));
        pb.setRecord(resultSet.getString(7));
        //pb.setRecord(resultSet.getString(8));
        pb.setRecord(resultSet.getString(9));
        pb.setRecord(resultSet.getString(10));
        mb.setFile(pb.getRecord());
      }
      return mb.getFile();
    }
    catch (SQLException ex) {
      System.out.println("qErr");
      return null;
    }finally{
      ConnectionManager.closeResultSet(resultSet);
      ConnectionManager.closeStatement(pStatement);
      ConnectionManager.closeConnection(dbConnection);
    }
  }

  public Vector TestgetDataInblurQuery(String [] keywords){
    int count=keywords.length;
    Connection dbConnection=null;
    PreparedStatement pStatement=null;
    ResultSet resultSet=null;
    try {
      dbConnection = ConnectionManager.getConnection();
      if(dbConnection!=null)
        System.out.println("OK!");
      String proList = "select * from motherboards where [description] like ?";
      for(int i=1;i<count;i++){
        proList=proList+" or [description] like ? ";
      }
      System.out.println(proList);
      //String proList = "select * from motherboards where [description] like ?";
      pStatement = dbConnection.prepareStatement(proList);
      for(int i=0;i<count;i++){
        //pStatement = dbConnection.prepareStatement(proList);
        pStatement.setString(i+1, keywords[i]="%"+keywords[i]+"%");
      }
      resultSet = pStatement.executeQuery();
      MotherboardsBean mb=new MotherboardsBean();
      while (resultSet.next()) {
        MotherboardsBean pb = new MotherboardsBean();
        //pb.setRecord(resultSet.getString(1));
        //pb.setRecord(resultSet.getString(2));
        pb.setRecord(resultSet.getString(3));
        pb.setRecord(resultSet.getString(4));
        pb.setRecord(resultSet.getString(5));
        pb.setRecord(resultSet.getString(6));
        pb.setRecord(resultSet.getString(7));
        //pb.setRecord(resultSet.getString(8));
        pb.setRecord(resultSet.getString(9));
        pb.setRecord(resultSet.getString(10));
        mb.setFile(pb.getRecord());
      }
      return mb.getFile();
    }
    catch (SQLException ex) {
      System.out.println("qErr");
      return null;
    }finally{
      ConnectionManager.closeResultSet(resultSet);
      ConnectionManager.closeStatement(pStatement);
      ConnectionManager.closeConnection(dbConnection);
    }
  }
}