treedatamodel.java

来自「固定资产管理」· Java 代码 · 共 79 行

import java.sql.*;
 //for standard JDBC packages
import java.math.*;

public class TreeDataModel {
   Connection conn;
   public TreeDataModel() {
   	conn = (new DbConn()).getConnection();
   }
   public int selCateCnt() {
      int cnt=0;
      if (conn == null) {
      	System.out.println("Can not connected yet!");
      	return -1;
      }
      try {
      Statement stmt = conn.createStatement();
      ResultSet rset = stmt.executeQuery ("select count(distinct cateid) from category");
      while (rset.next()) {
        cnt = rset.getInt(1);
      }
      rset.close();
      stmt.close();
      }
      catch (java.sql.SQLException s) {
	System.out.println("exception: " + s.getMessage());
      }
      return cnt;
   } 
    
   public void selSubCateCnt(int [] scnt) {
      int k=0;
      String sql;
      if (conn == null) {
      	System.out.println("Can not connected yet!");
      	return;
      }
      try {
      sql = "select cateid,count(subcateid) from category group by cateid";
      Statement stmt = conn.createStatement();
      ResultSet rset = stmt.executeQuery (sql);
      while (rset.next()) {
        scnt[k++] = rset.getInt(2);
      }
      rset.close();
      stmt.close();
      }
      catch (java.sql.SQLException s) {
	System.out.println("exception: " + s.getMessage());
      }
   }
   public void selCate(String [] data,int [] scnt,int cnt) {
      int k=0;
      String sql;
      if (conn == null) {
      	System.out.println("Can not connected yet!");
      	return;
      }
      try {
      sql = "SELECT CATEID,CATENAME,SUBCATEID,SUBCATENAME FROM category order by cateid,subcateid" ;
      Statement stmt = conn.createStatement();
      ResultSet rset = stmt.executeQuery (sql);
      rset.next();
      for (int i=0;i<cnt;i++) {
           data[k++] = rset.getString(2);
      	   for (int j=0;j<scnt[i];j++) {
              data[k++] = rset.getString(4);
              rset.next();
           }
      }
      rset.next();
      rset.close();
      stmt.close();
      }
      catch (java.sql.SQLException s) {
	System.out.println("exception: " + s.getMessage());
      }
    } 
}