struts基类覆盖+数据库操作类！呵呵…………

基类的！希望有高手指点一二！大家一起把IT弄好

package com.onlysoft.txl;
2

/**
4

* Title: 
5

*
6

* Description: 
7

*
8

* Copyright: Copyright (c) 2006
9

*
10

* Company: fishsoft
11

*
12

* @author Danny
13

* @version 1.0
14

*/
15

import org.apache.struts.action.Action;
17

import javax.servlet.http.HttpServletRequest;
18

import javax.servlet.http.HttpSession;
19

import java.sql.*;
20

import java.util.*;
21

import com.onlysoft.txl.util.*;
22

import javax.sql.DataSource;
23

import org.apache.log4j.Logger;
24

public class BaseAction extends Action {
26

public Connection conn = null;
27

public String userid = "";
28

public String username = "";
29

public String loginpwd = "";
30

public String realname = "";
31

public String mphone = "";
32

public boolean isLogin = false;
33

public DBUtil db;
34

public HttpSession session;
35

protected static Logger log = Logger.getLogger(BaseAction.class);
36

public void init(HttpServletRequest request) {
38

session = request.getSession();
40

HashMap loginInfo = session.getAttribute("loginInfo")==null?null:(HashMap) session.getAttribute("loginInfo");
41

if (loginInfo != null && !loginInfo.isEmpty()) {
42

isLogin = true;
43

userid = (String) loginInfo.get("userid");
44

username = (String) loginInfo.get("username");
45

realname = (String) loginInfo.get("realname");
46

mphone = (String) loginInfo.get("mphone");
47

loginpwd = (String) loginInfo.get("loginpwd");
48

}
49

db = new DBUtil();
50

//log.info("test");
51

try {
52

DataSource dataSource = getDataSource(request, "dataSource");
53

conn = dataSource.getConnection();
54

} catch (Exception ioe) {
55

ioe.printStackTrace();
56

}
57

}
58

public Integer saveHelperMore(String tableName, String sOpType,
60

ObjectBean oPara, ObjectBean oWhere
61

) throws Exception {
62

Integer iSize = new Integer(0);
63

try {
64

//System.out.println("sOpType==========:" + sOpType);
65

if (sOpType.equals("insert")) {
66

//System.out.println("oPara=========:" + oPara);
67

iSize = db.insOB(tableName, oPara, conn);
68

/*if (iSize == null || iSize.intValue() == 0) {
69

//this.toErrorInfo("表" + tableName + "保存失败!");
70

return;
71

}*/
72

} else if (sOpType.equals("update")) {
73

iSize = db.updOB(tableName, oPara, oWhere, conn);
74

} else if (sOpType.equals("delete")) {
75

iSize = db.delOB(tableName, oWhere, conn);
76

}
77

} catch (SQLException e) {
78

//this.toErrorInfo("数据保存失败");
79

//return;
80

}
81

return iSize;
82

}
83

public void saveHelperMore(String count,
85

String tableName, String sOpType,
86

ObjectBean oWhere,
87

HttpServletRequest request) throws
88

Exception {
89

Integer iSize;
90

try {
91

for (int i = 0; i < Integer.parseInt(count); i++) {
92

ObjectBean para = getPara(getTableColume(tableName),
93

Integer.toString(i), request);
94

if (sOpType.equals("insert")) {
95

iSize = db.insOB(tableName, para, conn);
96

if (iSize == null || iSize.intValue() == 0) {
97

//this.toErrorInfo("表" + tableName + "保存失败!");
98

return;
99

}
100

} else if (sOpType.equals("update")) {
101

db.updOB(tableName, para, oWhere, conn);
102

} else if (sOpType.equals("delete")) {
103

db.delOB(tableName, oWhere, conn);
104

}
105

}
106

} catch (SQLException e) {
107

//this.toErrorInfo("数据保存失败");
108

return;
109

}
110

}
111

112

protected ObjectBean getPara(HashMap mp, String suffix,
113

HttpServletRequest request) {
114

if (mp == null || mp.isEmpty()) {
115

return null;
116

}
117

ObjectBean para = new ObjectBean();
118

Vector data1 = mp.get("STRING") == null ? null :
119

(Vector) mp.get("STRING");
120

Vector data2 = mp.get("NOSTRING") == null ? null :
121

(Vector) mp.get("NOSTRING");
122

int count = 0;
123

if (data1 != null && !data1.isEmpty()) {
124

for (int i = 0; i < data1.size(); i++) {
125

if (request.getParameter(data1.elementAt(i) + suffix) != null) {
126

para.set(data1.elementAt(i),
127

request.getParameter(data1.elementAt(i) + suffix));
128

count++;
129

}
130

}
131

}
132

if (data2 != null && !data2.isEmpty()) {
133

for (int i = 0; i < data2.size(); i++) {
134

Object xxx = request.getParameter(data2.elementAt(i) + suffix);
135

if (xxx != null && !xxx.equals("")) {
136

para.set(data2.elementAt(i),
137

new StringBuffer("to_date('" +
138

xxx +
139

"','yyyy-mm-dd hh24:mi:ss')"));
140

count++;
141

}
142

}
143

}
144

if (count == 0) {
145

para = null;
146

}
147

return para;
148

}
149

150

protected HashMap getTableColume(String tableName) throws
151

SQLException {
152

HashMap para = new HashMap();
153

Vector para1 = new Vector(), para2 = new Vector();
154

ResultSetMetaData rs = null;
155

try {
156

rs = conn.createStatement().executeQuery(
157

"select * from " + tableName + " where 1=2 ").
158

getMetaData();
159

int r = rs.getColumnCount();
160

for (int i = 1; i < r + 1; i++) {
161

//System.out.println(rs.getColumnType(i));
162

if (rs.getColumnType(i) != 91) { //date
163

para1.add(rs.getColumnName(i));
164

} else {
165

para2.add(rs.getColumnName(i));
166

}
167

}
168

para.put("STRING", para1);
169

para.put("NOSTRING", para2);
170

} catch (SQLException e) {
171

e.printStackTrace();
172

throw e;
173

} finally {
174

}
175

return para;
176

}
177

178

protected String getNextID(String sFieldName, String sTableName) throws
179

Exception {
180

String sID = "";
181

try {
182

ResultSet rs = null;
183

String sSql = "select max(" + sFieldName + ")+1 as id from " + sTableName +
184

"";
185

//System.out.println("getNextID====sSql========:" + sSql);
186

rs = (ResultSet) db.doSql(sSql, db.QUERY_MODE, conn);
187

if (rs.next()) {
188

sID = rs.getString(1);
189

if (sID == null) {
190

sID = "1";
191

}
192

}
193

rs.close();
194

} catch (Exception ioe) {
195

ioe.printStackTrace();
196

}
197

return sID;
198

}
199

200

protected void destroy() {
201

try {
202

if (conn != null) {
203

conn.close();
204

conn = null;
205

}
206

} catch (Exception e) {
207

e.printStackTrace();
208

}
209

}
210

211

212

213

214

215

216

217

218

219

220

}
221

数据库操作的！不多说！实在的代码！

package com.onlysoft.txl.util;
2

/**
4

* Title: 
5

*
6

* Description: 
7

*
8

* Copyright: Copyright (c) 2006
9

*
10

* Company: fishsoft
11

*
12

* @author Danny
13

* @version 1.0
14

*/
15

import java.sql.*;
16

import javax.sql.*;
17

import java.util.*;
18

import java.io.*;
19

import java.math.BigDecimal;
20

public class DBUtil {
22

public final static int INSERT_MODE = 0;
24

public final static int UPDATE_MODE = 1;
25

public final static int DELETE_MODE = 2;
26

public final static int QUERY_MODE = 3;
27

public final static int MODIFY_MODE = 4;
28

private static final String sSeperator = ";";
30

private static final String sDatePattern = "yyyy/MM/dd";
31

private static final String sDateTimePattern = "yyyy/MM/dd hh:mm:ss S";
32

private String sTp = "java.math.BigDecimal;java.lang.Integer;java.lang.Double;java.lang.Float;java.lang.StringBuffer;";
33

private DataSource oDs;
35

// private Connection oCon;
36

boolean DEBUG = true;
37

private Statement oSt = null;
38

public DBUtil() {
40

}
42

private Integer modify(String s_sql, Connection oCont) throws Exception {
44

Integer iRs = null;
45

if (oSt != null) {
46

oSt.close();
47

oSt = null;
48

}
49

try {
50

oSt = oCont.createStatement();
51

iRs = new Integer(oSt.executeUpdate(s_sql));
52

} catch (SQLException sqle) {
53

throw sqle;
54

}
55

return iRs;
56

}
57

private ResultSet query(String s_sql, Connection oCont) throws Exception {
59

ResultSet oRs = null;
60

if (oSt != null) {
61

oSt.close();
62

oSt = null;
63

}
64

try {
65

oSt = oCont.createStatement();
66

oRs = oSt.executeQuery(s_sql);
67

} catch (SQLException sqle) {
68

throw sqle;
69

}
70

return oRs;
71

}
72

public Object doSql(String sSql, int i_mode, Connection oCont) throws
74

Exception {
75

try {
76

switch (i_mode) {
77

case INSERT_MODE:
78

case UPDATE_MODE:
79

case DELETE_MODE:
80

return modify(sSql, oCont);
81

case QUERY_MODE:
82

return query(sSql, oCont);
83

}
84

} catch (Exception e) {
85

throw e;
86

}
87

return null;
88

}
89

public Integer insOB(String tableName, ObjectBean res, Connection oCont) throws
91

Exception {
92

// res.canDB();
93

try {
94

String sql = "";
95

sql = "INSERT INTO " + tableName + " ( ";
96

Enumeration en = res.keys();
97

boolean f = false;
98

String key = "", val = "";
99

while (en.hasMoreElements()) {
100

if (f) {
101

key += ", ";
102

val += ", ";
103

} else {
104

f = true;
105

}
106

String k = (String) en.nextElement();
107

key += k;
108

String tp = res.get(k).getClass().getName();
109

if (this.sTp.indexOf(tp + ";") >= 0) {
110

val += "" + res.get(k) + "";
111

} else {
112

String temp = res.get(k)+"";
113

if (temp.equals("getdate()"))
114

val += "" + temp + "";
115

else
116

val += "'" + temp + "'";
117

}
118

}
119

sql += key + ") VALUES (" + val + ")";
120

121

//System.out.println("real sql:"+sql);
122

123

return (Integer)this.doSql(sql, this.INSERT_MODE, oCont);
124

} catch (Exception e) {
125

e.printStackTrace();
126

throw e;
127

}
128

}
129

130

public Integer updOB(String tableName, ObjectBean res, ObjectBean where,
131

Connection oCont) throws Exception {
132

// res.canDB();
133

try {
134

String sql = "";
135

sql = "UPDATE " + tableName + " SET ";
136

Enumeration en = res.keys();
137

boolean f = false;
138

while (en.hasMoreElements()) {
139

if (f) {
140

sql += ", ";
141

} else {
142

f = true;
143

}
144

String k = (String) en.nextElement();
145

String tp = res.get(k).getClass().getName();
146

if (this.sTp.indexOf(tp + ";") >= 0) {
147

sql += k + "=" + "" + res.get(k) + "";
148

} else {
149

sql += k + "=" + "'" + res.get(k) + "'";
150

}
151

}
152

sql += " WHERE ";
153

154

en = where.keys();
155

f = false;
156

while (en.hasMoreElements()) {
157

if (f) {
158

sql += "and ";
159

} else {
160

f = true;
161

}
162

String k = (String) en.nextElement();
163

String tp = where.get(k).getClass().getName();
164

if (this.sTp.indexOf(tp + ";") >= 0) {
165

sql += k + "=" + "" + where.get(k) + "";
166

} else {
167

sql += k + "=" + "'" + where.get(k) + "'";
168

}
169

}
170

171

return (Integer)this.doSql(sql, this.UPDATE_MODE, oCont);
172

} catch (Exception e) {
173

e.printStackTrace();
174

throw e;
175

}
176

}
177

178

public Integer delOB(String tableName, ObjectBean where, Connection oCont) throws
179

Exception {
180

try {
181

String sql = "";
182

sql = "DELETE FROM " + tableName + " WHERE ";
183

184

Enumeration en = where.keys();
185

boolean f = false;
186

while (en.hasMoreElements()) {
187

if (f) {
188

sql += "and ";
189

} else {
190

f = true;
191

}
192

String k = (String) en.nextElement();
193

String tp = where.get(k).getClass().getName();
194

if (this.sTp.indexOf(tp + ";") >= 0) {
195

sql += k + "=" + "" + where.get(k) + "";
196

} else {
197

sql += k + "=" + "'" + where.get(k) + "'";
198

}
199

}
200

201

return (Integer)this.doSql(sql, this.DELETE_MODE, oCont);
202

} catch (Exception e) {
203

e.printStackTrace();
204

throw e;
205

}
206

}
207

208

public ResultSet queOB(String tableName, String res, ObjectBean where,
209

Connection oCont) throws Exception {
210

try {
211

String sql = "";
212

sql = "SELECT " + res + " FROM " + tableName + " where ";
213

214

Enumeration en = where.keys();
215

boolean f = false;
216

while (en.hasMoreElements()) {
217

if (f) {
218

sql += "and ";
219

} else {
220

f = true;
221

}
222

String k = (String) en.nextElement();
223

String tp = where.get(k).getClass().getName();
224

if (this.sTp.indexOf(tp + ";") >= 0) {
225

sql += k + "=" + "" + where.get(k) + "";
226

} else {
227

sql += k + "=" + "'" + where.get(k) + "'";
228

}
229

}
230

231

return (ResultSet)this.doSql(sql, this.QUERY_MODE, oCont);
232

} catch (Exception e) {
233

e.printStackTrace();
234

throw e;
235

}
236

}
237

238

public static Vector getHashMapVByRSDec(ResultSet rs) throws Exception {
239

Vector resV = new Vector();
240

try {
241

if (rs != null) {
242

int count = 0;
243

Vector vColumnName = new Vector();
244

Vector vGetByType = new Vector();
245

while (rs.next()) {
246

ObjectBean ob = new ObjectBean();
247

if (count == 0) {
248

ResultSetMetaData rsm = rs.getMetaData();
249

count = rsm.getColumnCount();
250

for (int i = 1; i < count + 1; i++) {
251

Object oCn = rsm.getColumnName(i);
252

String sSt = rsm.getColumnTypeName(i);
253

vColumnName.addElement(oCn);
254

vGetByType.addElement(sSt);
255

ob.set(oCn, sqlGetByTypeDec(sSt, i, rs));
256

}
257

} else {
258

for (int i = 1; i < count + 1; i++) {
259

ob.set(vColumnName.elementAt(i - 1),
260

sqlGetByTypeDec( (String) vGetByType.elementAt(i -
261

1),
262

i, rs));
263

}
264

}
265

resV.addElement(ob);
266

}
267

}
268

} catch (Exception e) {
269

e.printStackTrace();
270

throw e;
271

} finally {
272

try {
273

if (rs != null) {
274

rs.close();
275

}
276

} catch (Exception e) {
277

e.printStackTrace();
278

throw e;
279

}
280

}
281

return resV;
282

}
283

284

public static HashMap getHashMapByRS(ResultSet rs) throws Exception {
285

HashMap resH = new HashMap();
286

try {
287

if (rs != null) {
288

int count = 0;
289

Vector vColumnName = new Vector();
290

Vector vGetByType = new Vector();
291

if (rs.next()) {
292

if (count == 0) {
293

ResultSetMetaData rsm = rs.getMetaData();
294

count = rsm.getColumnCount();
295

for (int i = 1; i < count + 1; i++) {
296

Object oCn = rsm.getColumnName(i);
297

String sSt = rsm.getColumnTypeName(i);
298

vColumnName.addElement(oCn);
299

vGetByType.addElement(sSt);
300

resH.put(oCn, sqlGetByTypeDec(sSt, i, rs));
301

}
302

} else {
303

for (int i = 1; i < count + 1; i++) {
304

resH.put(vColumnName.elementAt(i - 1),
305

sqlGetByTypeDec( (String) vGetByType.elementAt(i -
306

1),
307

i, rs));
308

}
309

}
310

}
311

}
312

} catch (Exception e) {
313

e.printStackTrace();
314

throw e;
315

} finally {
316

try {
317

if (rs != null) {
318

rs.close();
319

}
320

} catch (Exception e) {
321

e.printStackTrace();
322

throw e;
323

}
324

}
325

return resH;
326

}
327

328

public static List getListByRS(ResultSet rs) throws Exception {
329

List list = new ArrayList();
330

331

try {
332

if (rs != null) {
333

while (rs.next()) {
334

HashMap resH = new HashMap();
335

int count = 0;
336

Vector vColumnName = new Vector();
337

Vector vGetByType = new Vector();
338

if (count == 0) {
339

ResultSetMetaData rsm = rs.getMetaData();
340

count = rsm.getColumnCount();
341

for (int i = 1; i < count + 1; i++) {
342

Object oCn = rsm.getColumnName(i);
343

String sSt = rsm.getColumnTypeName(i);
344

vColumnName.addElement(oCn);
345

vGetByType.addElement(sSt);
346

resH.put(oCn, sqlGetByTypeDec(sSt, i, rs));
347

}
348

} else {
349

for (int i = 1; i < count + 1; i++) {
350

resH.put(vColumnName.elementAt(i - 1),
351

sqlGetByTypeDec( (String) vGetByType.elementAt(i -
352

1),
353

i, rs));
354

}
355

}
356

// System.out.println("hashmap value:"+resH);
357

list.add(resH);
358

}
359

}
360

} catch (Exception e) {
361

e.printStackTrace();
362

throw e;
363

} finally {
364

try {
365

if (rs != null) {
366

rs.close();
367

}
368

} catch (Exception e) {
369

e.printStackTrace();
370

throw e;
371

}
372

}
373

return list;
374

}
375

376

public static Object sqlGetByTypeDec(String eleType, int no, ResultSet rs) throws
377

Exception {
378

Object r = new Object();
379

try {
380

if (eleType.equalsIgnoreCase("datetime")) {
381

r = rs.getDate(no);
382

} else if (eleType.equalsIgnoreCase("date")) {
383

r = rs.getDate(no);
384

} else if (eleType.equalsIgnoreCase("bigint") ||
385

eleType.equalsIgnoreCase("smallint") ||
386

eleType.equalsIgnoreCase("LONGLONG")
387

|| eleType.equalsIgnoreCase("SHORT")
388

|| eleType.equalsIgnoreCase("INTEGER")) {
389

String ii = rs.getString(no);
390

r = ii == null ? null : new Integer(ii);
391

} else if (eleType.equalsIgnoreCase("boolean")) {
392

r = new Boolean(rs.getBoolean(no));
393

} else if (eleType.equalsIgnoreCase("float")) {
394

r = new Float(rs.getFloat(no));
395

} else if (eleType.equalsIgnoreCase("DECIMAL") ||
396

eleType.equalsIgnoreCase("NUMBER")) {
397

String s = rs.getString(no);
398

r = new BigDecimal(s == null || s.equals("") ? "0.00" : s);
399

} else if (eleType.equalsIgnoreCase("CLOB")) {
400

Clob value = rs.getClob(no);
401

if (value != null && value.length() > 0) {
402

return value.getSubString( (long) 1, (int) value.length());
403

}
404

} else {
405

r = rs.getString(no);
406

}
407

} catch (Exception e) {
408

e.printStackTrace();
409

throw e;
410

}
411

if (r == null) {
412

r = "";
413

}
414

return r;
415

}
416

417

}
418