KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > knowgate > jdc > JDCActivityInfo


1 package com.knowgate.jdc;
2
3 import java.util.ArrayList JavaDoc;
4 import java.sql.DriverManager JavaDoc;
5 import java.sql.Connection JavaDoc;
6 import java.sql.SQLException JavaDoc;
7 import java.sql.Statement JavaDoc;
8 import java.sql.ResultSet JavaDoc;
9
10 /**
11  * @author Sergio Montoro Ten
12  * @version 3.0
13  */
14 public class JDCActivityInfo {
15
16   private JDCProcessInfo[] aProcessInfo = null;
17
18   private void pgSqlActivity(Connection JavaDoc oConn) throws SQLException JavaDoc {
19     Statement JavaDoc oStmt;
20     ResultSet JavaDoc oRSet;
21     ArrayList JavaDoc aStats = new ArrayList JavaDoc();
22     oStmt = oConn.createStatement();
23     oRSet = oStmt.executeQuery("SELECT datid,datname,procpid,usesysid,usename,current_query,query_start FROM pg_stat_activity");
24     while (oRSet.next()) {
25       aStats.add (new JDCProcessInfo(oRSet.getString(1),oRSet.getString(2),
26                                      oRSet.getString(3),oRSet.getString(4),
27                                      oRSet.getString(5),oRSet.getString(6),
28                                      oRSet.getDate(7)));
29     } // wend
30 oRSet.close();
31     oStmt.close();
32     final int nProcs = aStats.size();
33     if (nProcs>0) {
34       aProcessInfo = new JDCProcessInfo[nProcs];
35       for (int p=0; p<nProcs; p++) {
36         aProcessInfo[p] = (JDCProcessInfo) aStats.get(p);
37       } // next
38 } // fi
39 }
40
41   public JDCActivityInfo(JDCConnection oConn) throws SQLException JavaDoc {
42     if (oConn.getDataBaseProduct()==JDCConnection.DBMS_POSTGRESQL) {
43       pgSqlActivity(oConn);
44     } // fi
45 }
46
47   public JDCActivityInfo(JDCConnectionPool oPool)
48     throws SQLException JavaDoc,ClassNotFoundException JavaDoc {
49     //Class.forName("org.postgresql.Driver");
50 //Connection oConn = DriverManager.getConnection("jdbc:postgresql://127.0.0.1:5432/econtainers2r","sa","laifee3B");
51 JDCConnection oConn = oPool.getConnection("activity_info");
52     if (oConn.getDataBaseProduct()==JDCConnection.DBMS_POSTGRESQL) {
53       pgSqlActivity(oConn);
54     } // fi
55 oConn.close();
56   }
57
58   public JDCProcessInfo[] processesInfo() {
59     return aProcessInfo;
60   }
61
62 }
63
Popular Tags