assetmodel.java

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

package project;

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

import java.sql.*;
import java.math.*;
import java.util.ArrayList;
public class AssetModel {
   String assetid="";
   String assetclass="";
   String assetname="";
   String assettype="";
   String assetP="";
   String assetuite="";
   String assetrem="";
   boolean v=true;
   DbConn dbc;
   Connection conn;

   public AssetModel() {

   }
   public AssetModel(String id,
                     String cn,
                     String na,
                     String ty,
                     String pp,
                     String pu,
                     String rm) {
         assetid=id;
        assetclass=cn;
        assetname=na;
        assettype=ty;
        assetP=pp;
        assetuite=pu;
        assetrem=rm;

   }

   public void setAll(String d) {
       assetid=d;
   }
   public boolean getv() {
          return v;
   }
   public String getAssetId() {
        return assetid;
   }
   public String getClassName() {
        return assetclass;
   }
   public String getAssetname() {
           return assetname;
   }
   public String getAssettype() {
              return assettype;
   }
   public String getAssetP() {
                return assetP;
   }
   public String getAssetuite() {
             return assetuite;
   }
   public String getAssetrem() {
                return assetrem;
   }

   public void selID() {
     String sql;
     dbc = new DbConn();
     conn = dbc.getConnection();
     sql = "SELECT * FROM ProductInfo WHERE P_ID = '"+assetid+"'";
     try {
     Statement stmt = conn.createStatement();
     ResultSet rset = stmt.executeQuery (sql);
     while (rset.next()) {
      assetclass = rset.getString(3);
     }
     conn.commit();
     rset.close();
     stmt.close();
     conn.close();
     }
     catch (java.sql.SQLException s) {
       System.out.println("exception: " + s.getMessage());
     }
   }

   public void insert() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String sql;
      try {
     sql="INSERT INTO ProductInfo (P_ID,P_BigClass,P_Name, P_TypeSize,P_Property,P_Unit,P_Note) ";
     sql=sql+"  values (?,?,?,?,?,?,?) ";
      PreparedStatement pstmt =  conn.prepareStatement(sql);
       pstmt.setString(1, assetid);
         pstmt.setString(2, assetclass);
           pstmt.setString(3,assetname);
             pstmt.setString(4, assettype);
               pstmt.setString(5, assetP);
                 pstmt.setString(6,  assetuite);
                   pstmt.setString(7, assetrem);
      pstmt.execute();
      conn.commit();
      conn.close();
        v=true;
      }
      catch (java.sql.SQLException s) {
          v=false;
        System.out.println("exception: " + s.getMessage());
      }
   }

   public void select() {
      String sql;
      dbc = new DbConn();
      conn = dbc.getConnection();
      sql = "SELECT * FROM ProductInfo WHERE P_ID = '"+assetid+"'";
      sql=sql+" AND NOT(P_Name IS NULL) ;";
      try {
      Statement stmt = conn.createStatement();
      ResultSet rset = stmt.executeQuery (sql);
      while (rset.next()) {
                assetid = rset.getString(2);
               assetname = rset.getString(4);
                assettype = rset.getString(5);
                assetP = rset.getString(6);
               assetuite = rset.getString(7);
               assetrem = rset.getString(8);

      }
      conn.commit();
      rset.close();
      stmt.close();
      conn.close();

      }
      catch (java.sql.SQLException s) {

        System.out.println("exception: " + s.getMessage());
      }
    }

    public void update() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String sql="UPDATE ProductInfo set P_ID=? , P_Name=? , P_TypeSize=? , P_Property=? ,";
                 sql=sql+"P_Unit=? , P_Note=?  WHERE P_ID=? ";

      try {
      PreparedStatement pstmt =conn.prepareStatement(sql);
      pstmt.setString(1,   assetclass);
      pstmt.setString(2, assetname);
      pstmt.setString(3, assettype);
      pstmt.setString(4, assetP);
      pstmt.setString(5, assetuite);
      pstmt.setString(6, assetrem);
      pstmt.setString(7, assetid);
      pstmt.execute();
      conn.commit();
      conn.close();
       v=true;
      }
      catch (java.sql.SQLException s) {
           v=false;
        System.out.println("exception: " + s.getMessage());
      }
   }

   public void delete() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String sql=" DELETE FROM ProductInfo WHERE  P_ID = '"+assetid+"'";
      try {
      PreparedStatement pstmt = conn.prepareStatement(sql);
      pstmt.execute();
      conn.commit();
      conn.close();
      v=true;
      }
      catch (java.sql.SQLException s) {
          v=false;
        System.out.println("exception: " + s.getMessage());
      }
   }
}