关于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 首发

评论

3 楼 freezingsky 2013-08-13  

jueyue 写道

freezingsky 写道

我的做法与此类似，不过，用的是spring3所支持util。

那个util?

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:util="http://www.springframework.org/schema/util"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
       http://www.springframework.org/schema/util
        http://www.springframework.org/schema/util/spring-util-3.0.xsd
        http://www.springframework.org/schema/mvc
        http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd">
<!--将SQL的相关内容放到Map中，并关联到DAO中。方便修改SQL，而不用修改类文件 -->

<util:map 	id="userOps" map-class="java.util.HashMap"
	 			key-type="java.lang.String"	value-type="java.lang.String"	>

2 楼 jueyue 2013-08-13  

freezingsky 写道

我的做法与此类似，不过，用的是spring3所支持util。

那个util?

1 楼 freezingsky 2013-08-05  

我的做法与此类似，不过，用的是spring3所支持util。