400-028-6601
建站资讯

网站建设资讯

为你提供网站建设行业资讯、网站优化知识、主机域名邮箱、网站开发常见问题等。

如何用Java实现.NET中DataTable功能

因为我本来就是搞net的,突然来了两个项目就是要用java以及oracle,便从各种方向上寻求net的影子,便有了今天这些工具类。不知道好不好,bug测试了一下了,性能上也只有经过项目来验证吧。其中一部分涉及到双数据库操作,所以也提了一种解决方案,写的不好,大家看看吧!

福安网站制作公司哪家好,找创新互联公司!从网页设计、网站建设、微信开发、APP开发、成都响应式网站建设公司等网站项目制作,到程序开发,运营维护。创新互联公司于2013年开始到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选创新互联公司。

我们先看效果,再说说怎么弄!

我们来试试如何用,我也写了一个测试数据。

然后我们在Junit中测试:

 
 
 
 
  1. @Test 
  2. public void joinTable() { 
  3. JingZongDB jzdb=new JingZongDB(); 
  4. DataTable dt1=jzdb.getDataTable("select * from newsType"); 
  5. DataTable dt2=jzdb.getDataTable("select * from news"); 
  6. DataTable dt=DataTable.joinTable(dt1, dt2, "id", "typeid"); 
  7. wl("新闻类型表:"+dt1.getRow().size()); 
  8. DataTable.outTable(dt1); 
  9. wl("新闻表:"+dt2.getRow().size()); 
  10. DataTable.outTable(dt2); 
  11. wl("合并后:"+dt.getRow().size()); 
  12. DataTable.outTable(dt); 
  13. } 
  14. private void wl(String s) { 
  15. System.out.println(s); 
  16. }  

最后结果为:

 
 
 
 
  1. 新闻类型表:4 
  2. id:1 typeName:学生工作 
  3. id:2 typeName:通知公告 
  4. id:3 typeName:招生简章 
  5. id:4 typeName:教务信息 
  6. 新闻表:16 
  7. id:1 typeid:1 newsName:学生工作1 
  8. id:2 typeid:1 newsName:学生工作2 
  9. id:3 typeid:1 newsName:学生工作3 
  10. id:4 typeid:1 newsName:学生工作4 
  11. id:5 typeid:2 newsName:通知公告1 
  12. id:6 typeid:2 newsName:通知公告2 
  13. id:7 typeid:2 newsName:通知公告3 
  14. id:8 typeid:2 newsName:通知公告4 
  15. id:9 typeid:3 newsName:招生简章1 
  16. id:10 typeid:3 newsName:招生简章2 
  17. id:11 typeid:3 newsName:招生简章3 
  18. id:12 typeid:3 newsName:招生简章4 
  19. id:13 typeid:4 newsName:教务信息1 
  20. id:14 typeid:4 newsName:教务信息2 
  21. id:15 typeid:4 newsName:教务信息3 
  22. id:16 typeid:4 newsName:教务信息4 
  23. 合并后:16 
  24. id:1 typeName:学生工作 id:1 typeid:1 newsName:学生工作1 
  25. id:1 typeName:学生工作 id:2 typeid:1 newsName:学生工作2 
  26. id:1 typeName:学生工作 id:3 typeid:1 newsName:学生工作3 
  27. id:1 typeName:学生工作 id:4 typeid:1 newsName:学生工作4 
  28. id:2 typeName:通知公告 id:5 typeid:2 newsName:通知公告1 
  29. id:2 typeName:通知公告 id:6 typeid:2 newsName:通知公告2 
  30. id:2 typeName:通知公告 id:7 typeid:2 newsName:通知公告3 
  31. id:2 typeName:通知公告 id:8 typeid:2 newsName:通知公告4 
  32. id:3 typeName:招生简章 id:9 typeid:3 newsName:招生简章1 
  33. id:3 typeName:招生简章 id:10 typeid:3 newsName:招生简章2 
  34. id:3 typeName:招生简章 id:11 typeid:3 newsName:招生简章3 
  35. id:3 typeName:招生简章 id:12 typeid:3 newsName:招生简章4 
  36. id:4 typeName:教务信息 id:13 typeid:4 newsName:教务信息1 
  37. id:4 typeName:教务信息 id:14 typeid:4 newsName:教务信息2 
  38. id:4 typeName:教务信息 id:15 typeid:4 newsName:教务信息3 
  39. id:4 typeName:教务信息 id:16 typeid:4 newsName:教务信息4  

#p#

现在说如何实现

1)实现.net数据库参数化。

 
 
 
 
  1. package cdu.yas.xykps.util; 
  2. import java.sql.Blob; 
  3. import java.sql.Date; 
  4. /** 
  5. * @功能描述 sql参数,sql执行时传递的参数用此类封装 
  6. * @可能的错误 
  7. * @作者 王磊 
  8. * @修改说明 
  9. * @修改人 
  10. */ 
  11. public class SqlParameter { 
  12. public SqlParameter(String type, String value) { 
  13. this.type = type; 
  14. this.value = value; 
  15. } 
  16. public SqlParameter(String type, int intValue) { 
  17. this.type = type; 
  18. this.intValue = intValue; 
  19. } 
  20. public SqlParameter(String type, boolean boolValue) { 
  21. this.type = type; 
  22. this.boolValue = boolValue; 
  23. } 
  24. public SqlParameter(String type, Date dateValue) { 
  25. this.type = type; 
  26. this.dateValue = dateValue; 
  27. } 
  28. public SqlParameter(String type, Blob blobValue) { 
  29. this.type = type; 
  30. this.blobValue = blobValue; 
  31. } 
  32. String type; 
  33. String value; 
  34. int intValue; 
  35. boolean boolValue; 
  36. Date dateValue; 
  37. Blob blobValue; 
  38. public String getType() { 
  39. return type; 
  40. } 
  41. public String getValue() { 
  42. return value; 
  43. } 
  44. public int getIntValue() { 
  45. return intValue; 
  46. } 
  47. public boolean getBoolValue() { 
  48. return boolValue; 
  49. } 
  50. public Date getDateValue() { 
  51. return dateValue; 
  52. } 
  53. public Blob getBlobValue() { 
  54. return blobValue; 
  55. } 
  56. public void setType(String type) { 
  57. this.type = type; 
  58. } 
  59. public void setValue(String value) { 
  60. this.value = value; 
  61. } 
  62. public void setIntValue(int intValue) { 
  63. this.intValue = intValue; 
  64. } 
  65. public void setBoolValue(boolean boolValue) { 
  66. this.boolValue = boolValue; 
  67. } 
  68. public void setDateValue(Date dateValue) { 
  69. this.dateValue = dateValue; 
  70. } 
  71. public void setBlobValue(Blob blobValue) { 
  72. this.blobValue = blobValue; 
  73. } 
  74. }  

2)后台参数执行:

 
 
 
 
  1. /** 
  2. * @功能描述 执行一条select语句返回一张数据表,支持多表查询 
  3. * @可能的错误 
  4. * @作者 王磊 
  5. * @修改说明 
  6. * @修改人 
  7. */ 
  8. public DataTable getDataTable(String sql, SqlParameter[] p) { 
  9. Connection conn = DB.createConn(); 
  10. PreparedStatement ps = DB.prepare(conn, sql); 
  11. DataTable t = null; 
  12. try { 
  13. addSqlParameter(ps, p); 
  14. ResultSet rs = ps.executeQuery(); 
  15. ResultSetMetaData rsmd = rs.getMetaData(); 
  16. List row = new ArrayList();// 表所有行集合 
  17. List col = null;// 行所有列集合 
  18. DataRow r = null; // 单独一行 
  19. DataColumn c = null;// 单独一列 
  20. // 此处开始循环读数据,每次往表格中插入一行记录 
  21. while (rs.next()) { 
  22. // 初始化行集合, 
  23. // 初始化列集合 
  24. col = new ArrayList(); 
  25. // 此处开始列循环,每次向一行对象插入一列 
  26. for (int i = 1; i <= rsmd.getColumnCount(); i++) { 
  27. String columnName = rsmd.getColumnName(i); 
  28. Object value = rs.getObject(columnName); 
  29. // 初始化单元列 
  30. c = new DataColumn(columnName, value); 
  31. // 将列信息加入列集合 
  32. col.add(c); 
  33. } 
  34. // 初始化单元行 
  35. r = new DataRow(col); 
  36. // 将行信息降入行结合 
  37. row.add(r); 
  38. } 
  39. // 得到数据表 
  40. t = new DataTable(row); 
  41. rs.close(); 
  42. rs = null; 
  43. } catch (SQLException e) { 
  44. e.printStackTrace(); 
  45. } finally { 
  46. DB.close(ps); 
  47. DB.close(conn); 
  48. } 
  49. return t; 
  50. }  

#p#

3)增加参数的方法:

 
 
 
 
  1. /** 
  2. * @功能描述 增加参数方法 
  3. * @可能的错误 需要测试全局数据共享问题,以及可能会扩展参数类型 
  4. * @作者 王磊 
  5. * @修改说明 
  6. * @修改人 
  7. */ 
  8. private void addSqlParameter(PreparedStatement ps, SqlParameter[] p) 
  9. throws SQLException { 
  10. for (int j = 0; j < p.length; j++) { 
  11. // wl(p[j].getValue() + "--" + p[j].getType() + "--" + j); 
  12. if (p[j].getType().equals("int")) { 
  13. ps.setInt(j + 1, p[j].getIntValue()); 
  14. } 
  15. if (p[j].type.equals("String")) { 
  16. ps.setString(j + 1, p[j].getValue()); 
  17. } 
  18. if (p[j].type.equals("boolean")) { 
  19. ps.setBoolean(j + 1, p[j].getBoolValue()); 
  20. } 
  21. if (p[j].type.equals("Date")) { 
  22. ps.setDate(j + 1, p[j].getDateValue()); 
  23. } 
  24. if (p[j].type.equals("Blob")) { 
  25. ps.setBlob(j + 1, p[j].getBlobValue()); 
  26. } 
  27. } 
  28. }  
  29. ----------/////////////////////////////////////////////// 
  30. public DataTable getByParentId(int pId) { 
  31. String sql = "select * from kpxz where fbh=? order by kpxzsx asc"; 
  32. SqlParameter[] p = new SqlParameter[1]; 
  33. p[0] = new SqlParameter("int", pId); 
  34. return db.getDataTable(sql, p); 
  35. }  

4)看看我们如何调用方法:

 
 
 
 
  1. public DataTable getByParentId(int pId) { 
  2. String sql = "select * from kpxz where fbh=? order by kpxzsx asc"; 
  3. SqlParameter[] p = new SqlParameter[1]; 
  4. p[0] = new SqlParameter("int", pId); 
  5. return db.getDataTable(sql, p); 
  6. }  

#p#

上面就是调用函数的具体方法,现在我们来详细说下DataTable,具体实现如下:

 
 
 
 
  1. package cdu.yas.xykps.util; 
  2. import java.util.ArrayList; 
  3. import java.util.List; 
  4. /** 
  5. * @功能描述 数据表,即是表格集合,为List类型,其中List中每一个对象是一个DataRow类(List) 
  6. * @可能的错误 
  7. * @作者 王磊 
  8. * @修改说明 
  9. * @修改人 
  10. */ 
  11. public class DataTable { 
  12. List row; 
  13. public DataTable() { 
  14. } 
  15. public DataTable(List r) { 
  16. row = r; 
  17. } 
  18. public List getRow() { 
  19. return row; 
  20. } 
  21. public void setRow(List row) { 
  22. this.row = row; 
  23. } 
  24. /** 
  25. * @功能描述 双表根据两表关联字段连接,要求两表必须包含公告字段,并且每一行数据公共字段相等 。dt1对应colname1 ,dt2 
  26. * 对应colName2 
  27. * @可能的错误 未完成 
  28. * @作者 王磊 
  29. * @修改说明 
  30. * @修改人 
  31. */ 
  32. public static DataTable joinTable(DataTable dt1, DataTable dt2, String colName1, 
  33. String colName2) { 
  34. List newRows = new ArrayList(); 
  35. List rows1 = dt1.getRow(); 
  36. List rows2 = dt2.getRow(); 
  37. int i1 = rows1.size(); 
  38. int i2 = rows2.size(); 
  39. List temp = new ArrayList(); 
  40. String tempC = ""; 
  41. if (i1 > i2) { 
  42. temp = rows1; 
  43. rows1 = rows2; 
  44. rows2 = temp; 
  45. tempC = colName1; 
  46. colName1 = colName2; 
  47. colName2 = tempC; 
  48. } 
  49. for (DataRow r1 : rows1) { 
  50. String value1 = r1.eval(colName1); 
  51. for (DataRow r2 : rows2) { 
  52. String value2 = r2.eval(colName2); 
  53. if (value1.equals(value2)) { 
  54. List cols = new ArrayList(); 
  55. for (DataColumn c : r1.getCol()) { 
  56. cols.add(c); 
  57. } 
  58. for (DataColumn c : r2.getCol()) { 
  59. cols.add(c); 
  60. } 
  61. DataRow rr = new DataRow(cols); 
  62. newRows.add(rr); 
  63. } 
  64. } 
  65. } 
  66. DataTable dt = new DataTable(newRows); 
  67. return dt; 
  68. } 
  69. public static void outTable(DataTable dt) { 
  70. for (DataRow r : dt.getRow()) { 
  71. for (DataColumn c : r.getCol()) { 
  72. System.out.print(c.getKey() + ":" + c.getValue() + " "); 
  73. } 
  74. wl(""); 
  75. } 
  76. } 
  77. public static void wl(String s) { 
  78. System.out.println(s); 
  79. } 
  80. }  

对应DataRow:

 
 
 
 
  1. package cdu.yas.xykps.util; 
  2. import java.sql.Blob; 
  3. import java.sql.Date; 
  4. import java.util.List; 
  5. /** 
  6. * @功能描述 数据行,即是表格中的每一行数据的集合,为List类型,其中List中每一个对象是一个DataColumn类(键值对) 
  7. * @可能的错误 当需要取得行数据中某一列时,若是类型转换不匹配会出错(例:1 若是数据项为字符串,我们取时候想取整形;); 
  8. * @作者 王磊 
  9. * @修改说明 由于取为空字符串时候会报类型转换的错误,便使用了异常处理 
  10. * @修改人 王磊 
  11. */ 
  12. public class DataRow { 
  13. List col; 
  14. /** 
  15. * @功能描述 返回指定DataColumn类型数据列对象 
  16. * @作者 王磊 
  17. */ 
  18. public DataColumn getColumnObject(String colName) { 
  19.  
  20. for (DataColumn c : col) { 
  21. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  22. try { 
  23. return c; 
  24. } catch (Exception e) { 
  25. System.out.println("错误描述:" + e.toString()); 
  26. } 
  27. } 
  28. } 
  29. return null; 
  30. } 
  31. /** 
  32. * @功能描述 返回指定Object类型数据列对象 
  33. * @作者 王磊 
  34. */ 
  35. public Object getColumn(String colName) { 
  36. for (DataColumn c : col) { 
  37. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  38. try { 
  39. return c.getValue(); 
  40. } catch (Exception e) { 
  41. System.out.println("错误描述:" + e.toString()); 
  42. } 
  43. } 
  44. } 
  45. return null; 
  46. } 
  47. /** 
  48. * @功能描述 返回指定int类型数据列对象 
  49. * @作者 王磊 
  50. */ 
  51. public int getIntColumn(String colName) { 
  52. for (DataColumn c : col) { 
  53. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  54. try { 
  55. return Integer.parseInt(c.getValue().toString()); 
  56. } catch (Exception e) { 
  57. System.out.println("错误描述:" + e.toString()); 
  58. } 
  59. } 
  60. } 
  61. return 0; 
  62. } 
  63. /** 
  64. * @功能描述 返回指定String类型数据列对象 
  65. * @作者 王磊 
  66. */ 
  67. public String getStringColumn(String colName) { 
  68. for (DataColumn c : col) { 
  69. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  70. try { 
  71. return c.getValue().toString(); 
  72. } catch (Exception e) { 
  73. System.out.println("错误描述:" + e.toString()); 
  74. } 
  75. } 
  76. } 
  77. return null; 
  78. } 
  79. /** 
  80. * @功能描述 返回指定String类型数据列对象 
  81. * @作者 王磊 
  82. */ 
  83. public String eval(String colName) { 
  84. for (DataColumn c : col) { 
  85. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  86. try { 
  87. return c.getValue() + "";// 此方法将屏蔽错误!!! 
  88. } catch (Exception e) { 
  89. System.out.println("错误描述:" + e.toString()); 
  90. } 
  91. } 
  92. } 
  93. return null; 
  94. } 
  95. /** 
  96. * @功能描述 返回指定Date类型数据列对象 
  97. * @作者 王磊 
  98. */ 
  99. public Date getDateColumn(String colName) { 
  100. for (DataColumn c : col) { 
  101. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  102. try { 
  103. return Date.valueOf(c.getValue().toString()); 
  104. } catch (Exception e) { 
  105. System.out.println("错误描述:" + e.toString()); 
  106. } 
  107. } 
  108. } 
  109. return null; 
  110. } 
  111. /** 
  112. * @功能描述 返回指定Blob类型数据列对象 
  113. * @作者 王磊 
  114. */ 
  115. public Blob getBlobColumn(String colName) { 
  116. for (DataColumn c : col) { 
  117. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  118. try { 
  119. return (Blob) c.getValue(); 
  120. } catch (Exception e) { 
  121. System.out.println("错误描述:" + e.toString()); 
  122. } 
  123. } 
  124. } 
  125. return null; 
  126. } 
  127. /** 
  128. * @功能描述 返回指定Blob类型数据列对象 
  129. * @作者 王磊 
  130. */ 
  131. public float getFloatColumn(String colName) { 
  132. for (DataColumn c : col) { 
  133. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  134. try { 
  135. return Float.parseFloat(c.getValue().toString()); 
  136. } catch (Exception e) { 
  137. System.out.println("错误描述:" + e.toString()); 
  138. } 
  139. } 
  140. } 
  141. return 0; 
  142. } 
  143. public DataRow(List c) { 
  144. col = c; 
  145. } 
  146. public List getCol() { 
  147. return col; 
  148. } 
  149. public void setCol(List col) { 
  150. this.col = col; 
  151. } 
  152. }  

然后数据列:

 
 
 
 
  1. package cdu.yas.xykps.util; 
  2. import java.util.Collection; 
  3. import java.util.HashMap; 
  4. import java.util.Map; 
  5. import java.util.Set; 
  6. /** 
  7. * @功能描述 数据列,也是最简单的数据项,相当于表格中的一个单元项目。 
  8. * 采用健值对思想,key为列名,value对应key值的单元格元素,为Object类型 
  9. * @可能的错误 
  10. * @作者 王磊 
  11. * @修改说明 
  12. * @修改人 
  13. */ 
  14. public class DataColumn { 
  15. String key; 
  16. Object value; 
  17. public DataColumn(String k, Object v) { 
  18. key = k; 
  19. value = v; 
  20. } 
  21. public String getKey() { 
  22. return key; 
  23. } 
  24. public Object getValue() { 
  25. return value; 
  26. } 
  27. public void setKey(String key) { 
  28. this.key = key; 
  29. } 
  30. public void setValue(Object value) { 
  31. this.value = value; 
  32. } 
  33. }  

如此一来便实现了java中的DataTable了。好了暂时这个样子了,我还封装了一个分页控件,也有点类似于net里面的分页控件,等下次大家一起看看吧。


本文题目:如何用Java实现.NET中DataTable功能
网页URL:http://www.hnjierui.cn/article/dhehcjo.html

其他资讯