关于jdbc跟代码分离自己的小方法

关于jdbc和代码分离自己的小方法
今天突然要写一个小的系统,因为什么都是新的,说要框架也要重新搭(bs下公司没有基础框架),ibatis自己没有怎么搭过,所以这次直接选择spring jdbc,但是要是喜欢ibatis的代码sql分离,所以自己百度了下发现spring 的jdbc代码分离有人写了,但是需要配置各个xml
,相信spring都是配置加自动的,所以自己,写了一部分,自动扫描map.xml然后加载,现在都是约定大于配置,这样我们约定放置sql的文件名和方式就可以了
下面是代码:
这个是主要的类,单例的

1. package com.jueyue.util;
3. import java.io.File;
4. import java.io.FileInputStream;
5. import java.io.FileNotFoundException;
6. import java.io.IOException;
7. import java.io.InputStream;
8. import java.util.List;
9. import java.util.Map;
10. import java.util.concurrent.ConcurrentHashMap;
12. import org.dom4j.Document;
13. import org.dom4j.DocumentException;
14. import org.dom4j.Element;
15. import org.dom4j.io.SAXReader;
17. import com.opensymphony.xwork2.util.logging.Logger;
18. import com.opensymphony.xwork2.util.logging.LoggerFactory;
19. /**
20. * sql map的基础类
21. * @author jueyue
22. *
23. */
24. public class SQLMap {
25. ? ?? ???
26. ? ?? ???private static Logger logger = LoggerFactory.getLogger(SQLMap.class);
28. ? ?? ???private Map<String, String> sqlContainer = null;
30. ? ?? ???private String sqlFilePath = "/com/jueyue/service/impl";
31. ? ?? ???
32. ? ?? ???private static SQLMap instance;
33. ? ?? ???
34. ? ?? ???public static SQLMap getInstance(){
35. ? ?? ?? ?? ?? ? if(instance == null){
36. ? ?? ?? ?? ?? ?? ?? ?? ?instance = new SQLMap();
37. ? ?? ?? ?? ?? ? }
38. ? ?? ?? ?? ?? ? return instance;
39. ? ?? ???}
41. ? ?? ???public SQLMap() {
42. ? ?? ?? ?? ?? ??
43. ? ?? ?? ?? ?? ? initSqlContainer();
44. ? ?? ???}
46. ? ?? ???public SQLMap(String sqlFilePath) {
48. ? ?? ?? ?? ?? ? this.sqlFilePath = sqlFilePath;
49. ? ?? ?? ?? ?? ? initSqlContainer();
50. ? ?? ???}
52. ? ?? ???public String getSql(String key) {
53. ? ?? ?? ?? ?? ? String sql = sqlContainer.get(key);
54. ? ?? ?? ?? ?? ? if (sql == null || "".equals(sql))
55. ? ?? ?? ?? ?? ?? ?? ?? ?logger.warn("不存在该SQL语句");
56. ? ?? ?? ?? ?? ? if (logger.isDebugEnabled()) {
57. ? ?? ?? ?? ?? ?? ?? ?? ?logger.debug("SQL:" + sql);
58. ? ?? ?? ?? ?? ? }
59. ? ?? ?? ?? ?? ? return sql;
60. ? ?? ???}
63. ? ?? ???private void initSqlContainer() {
64. ? ?? ?? ?? ?? ? sqlContainer = new ConcurrentHashMap<String, String>();
65. ? ?? ?? ?? ?? ? if (sqlFilePath == null || "".equals(sqlFilePath)) {
66. ? ?? ?? ?? ?throw new NullPointerException("sql语句文件不能为空!");
67. ? ?? ?? ?? ?? ? }
68. ? ?? ?? ?? ?? ? List<String> files = new ScanMapFile().getsqlMaps(sqlFilePath);
69. ? ?? ?? ?? ?? ? for (String file : files) {
70. ? ?? ?? ?? ?? ?? ?? ?? ?readSQLFromFile(file);
71. ? ?? ?? ?? ?? ? }
72. ? ?? ???}
74. ? ?? ???private void readSQLFromFile(String fileName) {
75. ? ?? ?? ?? ?? ? InputStream ips = null;
76. ? ?? ?? ?? ?? ? try {
77. ? ?? ?? ?? ?? ?? ?? ?? ?ips = new FileInputStream(new File(fileName));
78. ? ?? ?? ?? ?? ? } catch (FileNotFoundException e) {
79. ? ?? ?? ?? ?? ?? ?? ?? ?e.printStackTrace();
80. ? ?? ?? ?? ?? ? }
81. ? ?? ?? ?? ?? ? Document document = null;
82. ? ?? ?? ?? ?? ? SAXReader saxReader = new SAXReader();
83. ? ?? ?? ?? ?? ? try {
84. ? ?? ?? ?? ?? ?? ?? ?? ?document = saxReader.read(ips);
85. ? ?? ?? ?? ?? ? } catch (DocumentException e) {
86. ? ?? ?? ?? ?? ?? ?? ?? ?logger.error("读取系统中用到的SQL 语句XML出错");
87. ? ?? ?? ?? ?? ?? ?? ?? ?throw new RuntimeException("读取sql语句XML文件出错:" + e.getMessage());
88. ? ?? ?? ?? ?? ? }
89. ? ?? ?? ?? ?? ? Element root = document.getRootElement();
90. ? ?? ?? ?? ?? ? @SuppressWarnings("unchecked")
91. ? ?? ?? ?? ?? ? List<Element> sqlElements = (List<Element>)root.selectNodes("//sqlElement");
92. ? ?? ?? ?? ?? ? String key;
93. ? ?? ?? ?? ?? ? for (Element sql : sqlElements) {
94. ? ?? ?? ?? ?? ?? ?? ?? ?key=sql.attribute("key").getValue();
95. ? ?? ?? ?? ?? ?? ?? ?? ?if(sqlContainer.containsKey(key)){
96. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???logger.warn("key值:"+key+"重复");
97. ? ?? ?? ?? ?? ?? ?? ?? ?}
98. ? ?? ?? ?? ?? ?? ?? ?? ?sqlContainer.put(key, getSqlText(sql.getText()));
99. ? ?? ?? ?? ?? ? }
100. ? ?? ?? ?? ?? ? if (ips != null) {
101. ? ?? ?? ?? ?? ?? ?? ?? ?try {
102. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???ips.close();
103. ? ?? ?? ?? ?? ?? ?? ?? ?} catch (IOException e) {
104. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???logger.error("关闭输入流出错:" + e.getMessage());
105. ? ?? ?? ?? ?? ?? ?? ?? ?}
106. ? ?? ?? ?? ?? ? }
107. ? ?? ???}
108. ? ?? ???/**
109. ? ?? ?? ?* 出去无效字段
110. ? ?? ?? ?*/
111. ? ?? ???private String getSqlText(String text) {
112. ? ?? ?? ?? ?? ? return text.replaceAll("\\n", " ").replaceAll("\\t", " ");
113. ? ?? ???}
115. ? ?? ???public void setSqlFilePath(String sqlFilePath) {
116. ? ?? ?? ?? ?? ? this.sqlFilePath = sqlFilePath;
117. ? ?? ???}
119. ? ?? ???@Override
120. ? ?? ???protected void finalize() throws Throwable {
121. ? ?? ?? ?? ?? ? super.finalize();
122. ? ?? ?? ?? ?? ? if (sqlContainer != null) {
123. ? ?? ?? ?? ?? ?? ?? ?? ?sqlContainer.clear();
124. ? ?? ?? ?? ?? ?? ?? ?? ?sqlContainer = null;
125. ? ?? ?? ?? ?? ? }
127. ? ?? ???}
129. }

复制代码下面这个是扫描类

1. package com.copote.util;
3. import java.io.File;
4. import java.util.ArrayList;
5. import java.util.List;
7. /**
8. * 扫描service下面的所有map.xml
9. *?
10. * @author jueyue 2013年8月5日
11. */
12. public class ScanMapFile {
13. ? ?? ???
14. ? ?? ???private List<String> sqls;
15. ? ?? ???
16. ? ?? ???public ScanMapFile(){
17. ? ?? ?? ?? ?? ? sqls =??new ArrayList<String>();
18. ? ?? ???}
19. ? ?? ???
20. ? ?? ???public??List<String> getsqlMaps(String path){
21. ? ?? ?? ?? ?? ? GetSql(ScanMapFile.class.getResource(path).getPath());
22. ? ?? ?? ?? ?? ? return sqls;
23. ? ?? ???}
25. ? ?? ???/*
26. ? ?? ?? ?* 递归调用查找指定文件加下所有文件
27. ? ?? ?? ?*/
28. ? ?? ???private void GetSql(String path) {
29. ? ?? ?? ?? ?? ? File rootDir = new File(path);
30. ? ?? ?? ?? ?? ? if (!rootDir.isDirectory()) {
31. ? ?? ?? ?? ?? ?? ?? ?? ?if(rootDir.getName().equalsIgnoreCase("map.xml")){
32. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???sqls.add(rootDir.getAbsolutePath());
33. ? ?? ?? ?? ?? ?? ?? ?? ?}
34. ? ?? ?? ?? ?? ? } else {
35. ? ?? ?? ?? ?? ?? ?? ?? ?String[] fileList = rootDir.list();
36. ? ?? ?? ?? ?? ?? ?? ?? ?for (int i = 0; i < fileList.length; i++) {
37. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???path = rootDir.getAbsolutePath() + "\" + fileList[i];
38. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???GetSql(path);
39. ? ?? ?? ?? ?? ?? ?? ?? ?}
40. ? ?? ?? ?? ?? ? }
41. ? ?? ???}
42. }

复制代码我们扫描的是所有的map.xml这样就加载了所有的sql

1. <?xml version="1.0" encoding="UTF-8"?>
2. <sqls>
3. ? ?? ???<sqlElement key="account.login">
4. ? ?? ?? ?? ?? ? <![CDATA[
5. ? ?? ?? ?? ?? ?? ?? ?? ?select *??from user
6. ? ?? ???</sqlElement>
7. </sqls>

复制代码然后在我们的dao里面这样写

1. @Override
2. ? ?? ???public AccountEntity login(AccountEntity account) {
3. ? ?? ?? ?? ?? ? String sql = SQLMap.getInstance().getSql("account.login");//加载sql
4. ? ?? ?? ?? ?? ? List<AccountEntity> temp = jdbcTemplate.query(sql,
5. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???new Object[] { account.getVAcctCode(), account.getVAcctPwd(),
6. ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???account.getCorgId() }, new AccountRowMapper());
7. ? ?? ?? ?? ?? ? return temp.size() == 1?temp.get(0):null;
8. ? ?? ???}

复制代码这样我们就获取了对于的sql,就分离了,而且自动扫描
最后记得在web.xml添加启动监听,进行初始化


jeecg 首发 1 楼 freezingsky 1 小时前   我的做法与此类似，不过，用的是spring3所支持util。

查看更多 下一篇