如何用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. private void wl(String s) { 
  14. System.out.println(s); 
  15. }  

最后结果为:

 
 
 
 
  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. public SqlParameter(String type, int intValue) { 
  16. this.type = type; 
  17. this.intValue = intValue; 
  18. public SqlParameter(String type, boolean boolValue) { 
  19. this.type = type; 
  20. this.boolValue = boolValue; 
  21. public SqlParameter(String type, Date dateValue) { 
  22. this.type = type; 
  23. this.dateValue = dateValue; 
  24. public SqlParameter(String type, Blob blobValue) { 
  25. this.type = type; 
  26. this.blobValue = blobValue; 
  27. String type; 
  28. String value; 
  29. int intValue; 
  30. boolean boolValue; 
  31. Date dateValue; 
  32. Blob blobValue; 
  33. public String getType() { 
  34. return type; 
  35. public String getValue() { 
  36. return value; 
  37. public int getIntValue() { 
  38. return intValue; 
  39. public boolean getBoolValue() { 
  40. return boolValue; 
  41. public Date getDateValue() { 
  42. return dateValue; 
  43. public Blob getBlobValue() { 
  44. return blobValue; 
  45. public void setType(String type) { 
  46. this.type = type; 
  47. public void setValue(String value) { 
  48. this.value = value; 
  49. public void setIntValue(int intValue) { 
  50. this.intValue = intValue; 
  51. public void setBoolValue(boolean boolValue) { 
  52. this.boolValue = boolValue; 
  53. public void setDateValue(Date dateValue) { 
  54. this.dateValue = dateValue; 
  55. public void setBlobValue(Blob blobValue) { 
  56. this.blobValue = blobValue; 
  57. }  

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. r = new DataRow(col); 
  35. // 将行信息降入行结合 
  36. row.add(r); 
  37. // 得到数据表 
  38. t = new DataTable(row); 
  39. rs.close(); 
  40. rs = null; 
  41. } catch (SQLException e) { 
  42. e.printStackTrace(); 
  43. } finally { 
  44. DB.close(ps); 
  45. DB.close(conn); 
  46. return t; 
  47. }  

#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. if (p[j].type.equals("String")) { 
  15. ps.setString(j + 1, p[j].getValue()); 
  16. if (p[j].type.equals("boolean")) { 
  17. ps.setBoolean(j + 1, p[j].getBoolValue()); 
  18. if (p[j].type.equals("Date")) { 
  19. ps.setDate(j + 1, p[j].getDateValue()); 
  20. if (p[j].type.equals("Blob")) { 
  21. ps.setBlob(j + 1, p[j].getBlobValue()); 
  22. }  
  23. ----------/////////////////////////////////////////////// 
  24. public DataTable getByParentId(int pId) { 
  25. String sql = "select * from kpxz where fbh=? order by kpxzsx asc"; 
  26. SqlParameter[] p = new SqlParameter[1]; 
  27. p[0] = new SqlParameter("int", pId); 
  28. return db.getDataTable(sql, p); 
  29. }  

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. public DataTable(List r) { 
  15. row = r; 
  16. public List getRow() { 
  17. return row; 
  18. public void setRow(List row) { 
  19. this.row = row; 
  20. /** 
  21. * @功能描述 双表根据两表关联字段连接,要求两表必须包含公告字段,并且每一行数据公共字段相等 。dt1对应colname1 ,dt2 
  22. * 对应colName2 
  23. * @可能的错误 未完成 
  24. * @作者 王磊 
  25. * @修改说明 
  26. * @修改人 
  27. */ 
  28. public static DataTable joinTable(DataTable dt1, DataTable dt2, String colName1, 
  29. String colName2) { 
  30. List newRows = new ArrayList(); 
  31. List rows1 = dt1.getRow(); 
  32. List rows2 = dt2.getRow(); 
  33. int i1 = rows1.size(); 
  34. int i2 = rows2.size(); 
  35. List temp = new ArrayList(); 
  36. String tempC = ""; 
  37. if (i1 > i2) { 
  38. temp = rows1; 
  39. rows1 = rows2; 
  40. rows2 = temp; 
  41. tempC = colName1; 
  42. colName1 = colName2; 
  43. colName2 = tempC; 
  44. for (DataRow r1 : rows1) { 
  45. String value1 = r1.eval(colName1); 
  46. for (DataRow r2 : rows2) { 
  47. String value2 = r2.eval(colName2); 
  48. if (value1.equals(value2)) { 
  49. List cols = new ArrayList(); 
  50. for (DataColumn c : r1.getCol()) { 
  51. cols.add(c); 
  52. for (DataColumn c : r2.getCol()) { 
  53. cols.add(c); 
  54. DataRow rr = new DataRow(cols); 
  55. newRows.add(rr); 
  56. DataTable dt = new DataTable(newRows); 
  57. return dt; 
  58. public static void outTable(DataTable dt) { 
  59. for (DataRow r : dt.getRow()) { 
  60. for (DataColumn c : r.getCol()) { 
  61. System.out.print(c.getKey() + ":" + c.getValue() + " "); 
  62. wl(""); 
  63. public static void wl(String s) { 
  64. System.out.println(s); 
  65. }  

对应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. return null; 
  27. /** 
  28. * @功能描述 返回指定Object类型数据列对象 
  29. * @作者 王磊 
  30. */ 
  31. public Object getColumn(String colName) { 
  32. for (DataColumn c : col) { 
  33. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  34. try { 
  35. return c.getValue(); 
  36. } catch (Exception e) { 
  37. System.out.println("错误描述:" + e.toString()); 
  38. return null; 
  39. /** 
  40. * @功能描述 返回指定int类型数据列对象 
  41. * @作者 王磊 
  42. */ 
  43. public int getIntColumn(String colName) { 
  44. for (DataColumn c : col) { 
  45. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  46. try { 
  47. return Integer.parseInt(c.getValue().toString()); 
  48. } catch (Exception e) { 
  49. System.out.println("错误描述:" + e.toString()); 
  50. return 0; 
  51. /** 
  52. * @功能描述 返回指定String类型数据列对象 
  53. * @作者 王磊 
  54. */ 
  55. public String getStringColumn(String colName) { 
  56. for (DataColumn c : col) { 
  57. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  58. try { 
  59. return c.getValue().toString(); 
  60. } catch (Exception e) { 
  61. System.out.println("错误描述:" + e.toString()); 
  62. return null; 
  63. /** 
  64. * @功能描述 返回指定String类型数据列对象 
  65. * @作者 王磊 
  66. */ 
  67. public String eval(String colName) { 
  68. for (DataColumn c : col) { 
  69. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  70. try { 
  71. return c.getValue() + "";// 此方法将屏蔽错误!!! 
  72. } catch (Exception e) { 
  73. System.out.println("错误描述:" + e.toString()); 
  74. return null; 
  75. /** 
  76. * @功能描述 返回指定Date类型数据列对象 
  77. * @作者 王磊 
  78. */ 
  79. public Date getDateColumn(String colName) { 
  80. for (DataColumn c : col) { 
  81. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  82. try { 
  83. return Date.valueOf(c.getValue().toString()); 
  84. } catch (Exception e) { 
  85. System.out.println("错误描述:" + e.toString()); 
  86. return null; 
  87. /** 
  88. * @功能描述 返回指定Blob类型数据列对象 
  89. * @作者 王磊 
  90. */ 
  91. public Blob getBlobColumn(String colName) { 
  92. for (DataColumn c : col) { 
  93. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  94. try { 
  95. return (Blob) c.getValue(); 
  96. } catch (Exception e) { 
  97. System.out.println("错误描述:" + e.toString()); 
  98. return null; 
  99. /** 
  100. * @功能描述 返回指定Blob类型数据列对象 
  101. * @作者 王磊 
  102. */ 
  103. public float getFloatColumn(String colName) { 
  104. for (DataColumn c : col) { 
  105. if (c.getKey().toUpperCase().equals(colName.toUpperCase())) { 
  106. try { 
  107. return Float.parseFloat(c.getValue().toString()); 
  108. } catch (Exception e) { 
  109. System.out.println("错误描述:" + e.toString()); 
  110. return 0; 
  111. public DataRow(List c) { 
  112. col = c; 
  113. public List getCol() { 
  114. return col; 
  115. public void setCol(List col) { 
  116. this.col = col; 
  117. }  

然后数据列:

 
 
 
 
  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. public String getKey() { 
  21. return key; 
  22. public Object getValue() { 
  23. return value; 
  24. public void setKey(String key) { 
  25. this.key = key; 
  26. public void setValue(Object value) { 
  27. this.value = value; 
  28. }  

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

网页题目:如何用Java实现.NET中DataTable功能
路径分享:http://www.shufengxianlan.com/qtweb/news29/301129.html

网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联