catemodel.java

来自「一个企业小型固定资产系统的源代码。发布出来让刚学习java的人研究。」· Java 代码 · 共 159 行

package project;

/*
 *CateModel.java：建立资产类别实体类。
 *包括：与数据库进行增、删、改、查操作。
 */

import java.sql.*;
import java.math.*;

public class CateModel {
   String cateid;
   String catename;

   DbConn dbc;
   Connection conn;
   Connection conn2;
   boolean verifycate;
   public CateModel() {
   }
   public CateModel(String n,String e) {
        cateid = n;
        catename = e;

   }

   public void setAll(String p,String r) {
        catename = p;

   }

   public void selch(String p) {
         cateid = p;

   }


   public String getCateId() {
        return cateid;
   }
   public String getCateName() {
        return catename;
   }


   public void insert() {
      dbc = new DbConn();
      conn = dbc.getConnection();
    String sql="INSERT INTO ProductInfo ( P_ID ,P_BigClass ) VALUES ( (?) , (?) )";
      try {
      PreparedStatement pstmt = conn.prepareStatement(sql);
      pstmt.setString(1,  cateid);
      pstmt.setString(2, catename);
      pstmt.executeUpdate();
      pstmt.close();
      conn.commit();
      conn.close();
      verifycate=true;
      }
      catch (java.sql.SQLException s) {
          verifycate=false;
        System.out.println("exception: " + s.getMessage());
      }
   }
   public void selch() {
         String sql;
         dbc = new DbConn();
         conn = dbc.getConnection();
         sql = "SELECT  * FROM ProductInfo WHERE P_ID  LIKE '"+cateid+"'";
         sql =sql+" AND P_Name IS NULL ;";
         try {
         Statement stmt = conn.createStatement();
         ResultSet rset = stmt.executeQuery (sql);
         while (rset.next()) {
           catename = rset.getString(3);
         }
         conn.commit();
         rset.close();
         stmt.close();
         conn.close();
         }
         catch (java.sql.SQLException s) {
           System.out.println("exception: " + s.getMessage());
         }
    }

    public void update(String nid) {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String idtemp="";
      String cntemp="";
     String sqlsel="SELECT  * FROM ProductInfo WHERE P_ID  LIKE '"+cateid+"'";
     String sqlsel2="SELECT  * FROM ProductInfo WHERE P_ID  LIKE '"+cateid+".%"+"'";
    // sqlsel=sqlsel+" OR P_ID  = '"+cateid+"'";
     String sqlupd="UPDATE ProductInfo SET P_ID = ? ,P_BigClass = ?   WHERE  P_NO= ?";
     int pno;
     int pno2;
      try {
          Statement stmt1 = conn.createStatement();
          ResultSet rset = stmt1.executeQuery (sqlsel);
       while (rset.next()) {
           pno=rset.getInt(1);
           StringBuffer bftna=new StringBuffer(rset.getString(3));
           cntemp=bftna.replace(bftna.lastIndexOf(".")+1,bftna.length(),catename).toString();;
      PreparedStatement pstmt =conn.prepareStatement(sqlupd);
      pstmt.setString(1,nid);
      pstmt.setString(2,cntemp);
      pstmt.setInt(3, pno);
      pstmt.executeUpdate();
       }
       rset.close();
        Statement stmt2 = conn.createStatement();
        ResultSet rset2 = stmt2.executeQuery (sqlsel2);
     while (rset2.next()) {
       /*  if(nid.lastIndexOf(".")==-1){
             break;
         }*/
         pno2=rset2.getInt(1);
          StringBuffer bftid=new StringBuffer(rset2.getString(2));
         idtemp= bftid.replace(0,nid.length(),nid).toString();
         StringBuffer bftna=new StringBuffer(rset2.getString(3));
         cntemp=bftna.replace(0,cntemp.length(),cntemp).toString();
    PreparedStatement pstmt2 =conn.prepareStatement(sqlupd);
    pstmt2.setString(1,idtemp);
    pstmt2.setString(2,cntemp);
    pstmt2.setInt(3, pno2);
    pstmt2.executeUpdate();
     }
     rset2.close();
      conn.commit();
      conn.close();
      verifycate=true;
      }
      catch (java.sql.SQLException s) {
          verifycate=false;
        System.out.println("exception: " + s.getMessage());
      }
   }

   public void delete() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String sql=" DELETE FROM ProductInfo WHERE  P_ID = '"+cateid+"'";

      try {
      PreparedStatement pstmt = conn.prepareStatement(sql);
      pstmt.execute();
      pstmt.close();
      conn.commit();
      conn.close();
       verifycate=true;
      }
      catch (java.sql.SQLException s) {
           verifycate=false;
        System.out.println("exception: " + s.getMessage());
      }
   }
}