package com.am;

import java.text.*;
import java.util.*;
import java.lang.*;
import java.io.*;
import java.sql.*;
import com.am.*;
public class DataBase {

  // Fields
 public Connection conn;
  public Statement stm=null;
  public PreparedStatement pstm;
  public ResultSet rs=null;
  boolean connected;

  // Constructors
  public DataBase() { }

  public ResultSet QuerySQL(String sql) {
     OpenDB od=new OpenDB();
     od.getConnection();
     try{
     stm = conn.createStatement();
     rs = stm.executeQuery(sql);}catch(Exception ex){}
  return rs;
  }
  public Vector getOnePage(String sql,int page,int records)
          {
                  //第一個為總頁數*/
                  //第二...個為Hashtable*/
                  Vector vect = new Vector();
                  int zdrecords = records;
                  try
                  {    OpenDB od=new OpenDB();
                        conn= od.getConnection();

                          //查詢總頁數
                  //	pstm.clearBatch();
                          stm = conn.createStatement();

                          rs = stm.executeQuery(sql);

                          int rows = 0;
                          while(rs.next())
                          {
                                  rows++;
                          }
                          int sum = rows/zdrecords;
                          if(rows%zdrecords!=0||rows==0)sum++;
                          vect.add(""+sum);

                          rs.close();

                          //移到當前行
                  //	pstm.clearBatch();
                  stm = conn.createStatement();
                  rs = stm.executeQuery(sql);

                          rows = (page-1)*zdrecords;
                          rs.absolute(rows+1);
                          rs.previous();

                          DealString ds = new DealString();

                          //查詢當前頁
                          int j=0;
                          while(rs.next())
                          {
                                  if(j==zdrecords)break;
                                  j++;

                                  ResultSetMetaData rsmd = rs.getMetaData();
                                  int cols = rsmd.getColumnCount();
                                  Hashtable hash = new Hashtable();
                                  for(int i=1;i<=cols;i++)
                                  {
                                          String field = ds.toString(rsmd.getColumnName(i));
                                          String value = ds.toString(rs.getString(i));
                                          hash.put(field,value);
                                  }
                                  vect.add(hash);
                          }
                  }catch(SQLException sqle){System.out.println("DataBase::getOnePage(String,int,int)執行SQL語句 "+sql+" 分頁至第 "+page+" 頁時出錯;錯誤為:"+sqle);}
                  finally{
                          if(rs!=null){
                                  try{
                                  rs.close();
                                  }catch(SQLException e){System.out.println("DataBase::getOnePage(String,int,int)調用SQL語句 "+sql+" 時出錯;\r\n錯誤為:"+e);}
                          }


                  }
                  return vect;
          }
public void releaseConn()
          {try{
              conn.close();
              }catch(Exception ex){}
             }
}