|
1 package com.quikj.server.framework;
2
3 import java.sql.*;
4
5 public class AceSQLMessage implements AceMessageInterface
6 {
7 public static final int SQL_EXECUTED = 1;
8 public static final int SQL_ERROR = 2;
9
10 protected AceSQLMessage(int status,
11 int operation_id,
12 ResultSet result,
13 ResultSet[] results,
14 int affected_rows,
15 AceThread parent,
16 AceThread child,
17 int num_statements,
18 Object  user_parm)
19 {
20 this.status = status;
21 this.result = result;
22 this.results = results;
23 this.parent = parent;
24 this.child = child;
25 operationId = operation_id;
26 userParm = user_parm;
27 affectedRows = affected_rows;
28 numStatementsExecuted = num_statements;
29 }
30
31 protected AceSQLMessage(int status,
32 int operation_id,
33 ResultSet result,
34 ResultSet[] results,
35 AceThread parent,
36 AceThread child,
37 int num_statements,
38 Object user_parm)
39 {
40 this(status, operation_id, result, results, 0, parent, child, num_statements, user_parm);
41 }
42
43 protected AceSQLMessage(int status,
44 int operation_id,
45 AceThread parent,
46 AceThread child,
47 int num_statements,
48 Object user_parm)
49 {
50 this(status, operation_id, null, null, 0, parent, child, num_statements, user_parm);
51 }
52
53 protected AceSQLMessage(int status,
54 int operation_id,
55 int affected_rows,
56 AceThread parent,
57 AceThread child,
58 int num_statements,
59 Object user_parm)
60 {
61 this(status, operation_id, null, null, affected_rows, parent, child, num_statements, user_parm);
62 }
63
64 public String messageType()
65 {
66 return new String ("AceSQLMessage");
67 }
68
69 public boolean resultAvailable()
70 {
71 try
72 {
73 if ((result == null) || (result.next() == false))
74 {
75 return false;
76 }
77 }
78 catch (SQLException ex)
79 {
80 AceLogger.Instance().log(AceLogger.ERROR,
81 AceLogger.SYSTEM_LOG,
82 parent.getName()
83 + "- AceSQLMessage.resultAvailable() -- SQLException checking Resultset : "
84 + ex.getMessage());
85 return false;
86 }
87
88 return true;
89 }
90
91 public boolean multipleResultsAvailable()
92 {
93 if (results == null)
94 {
95 return false;
96 }
97
98 return true;
99 }
100
101 public ResultSet getResultSet()
102 {
103 return result;
104 }
105
106 public ResultSet[] getMultipleResults()
107 {
108 return results;
109 }
110
111 public int getAffectedRows()
112 {
113 return affectedRows;
114 }
115
116 public int getStatus()
117 {
118 return status;
119 }
120
121 public Object getUserParm()
122 {
123 return userParm;
124 }
125
126 public AceThread getParent()
127 {
128 return parent;
129 }
130
131 public int getOperationId()
132 {
133 return operationId;
134 }
135
136 public AceThread getChild()
137 {
138 return child;
139 }
140
141 private int status;
142 private Object userParm;
143 private ResultSet result;
144 private ResultSet[] results;
145 private int affectedRows;
146 private AceThread parent;
147 private AceThread child;
148 private int operationId;
149 private int numStatementsExecuted;
150 }
151 |
Popular Tags |
Java API By Example, From Geeks To Geeks.