先前一直都是用的直接用加载驱动 然后创建连接进行操作数据 如果我的数据库换了 那么要修改的地方也比较多 不利于维护 所以就想到了将所有配置连接信息都用xml封装起来 以至于我每次都只要修改一下我的xml配置文件 不需要修改我的代码 这也就有了下面的操作 将驱动 url 用户名和密码都写到xml文件里面
1 <?xml version="1.0" encoding="UTF-8"?> 2 <database> 3 <driver>com.mysql.jdbc.Driver</driver> 4 <url>jdbc:mysql://localhost:3306/employee</url> 5 <user>root</user> 6 <password>root</password> 7 </database>
有了xml 文件之后就需要来进行解析
1 // 使用dom4j解析xml
2 private static void parseXmlInfo() {
3 // 创建saxreader对象
4 SAXReader saxReader = new SAXReader();
5 try {
6 // 加载xml文件
7 Document doc = saxReader.read(DBUtil.class.getResourceAsStream("/jdbc.xml"));
8 // 获得根元素
9 Element root = doc.getRootElement();
10 // 获得对应的元素的文本值
11 driver = root.elementText("driver");
12 url = root.elementText("url");
13 user = root.elementText("user");
14 password = root.elementText("password");
15
16 } catch (DocumentException e) {
17 // TODO Auto-generated catch block
18 e.printStackTrace();
19 }
20 }
解析完了之后就可以获取连接操作数据库
将增删改封装到一个方法里面 以后每次只需要写sql语句就可以
1 /**
2 * 修改数据的方法
3 *
4 * @param sql
5 * @param values sql中所有？的值
6 *
7 * @return 0表示修改失败，其他表示修改成功
8 */
9 public static int update(String sql, Object[] values) {
10 PreparedStatement ps = null;
11 ResultSet rs = null;
12 // 获取连接
13 getConnection();
14 try {
15 // 创建prepareStatement
16 ps = conn.prepareStatement(sql);
17 System.out.println(ps);
18 for (int i = 0; i < values.length; i++) {
19 ps.setObject(i + 1, values[i]);
20 }
21 System.out.println(ps);
22 // 执行修改语句返回受影响的行数
23 int num = ps.executeUpdate();
24 System.out.println(num);
25 } catch (SQLException e) {
26 e.printStackTrace();
27 } finally {
28 // 关闭资源
29 if (ps != null) {
30 try {
31 ps.close();
32 } catch (SQLException e) {
33 // TODO Auto-generated catch block
34 e.printStackTrace();
35 }
36 }
37 }
38 return 0;
39 }
将查询封装在一个方法里面
1 /**
2 * 查询的方法
3 *
4 * @param sql
5 * @param values sql中？的值
6 * @return 查询到的数据
7 */
8 public static List<Map<String, String>> query(String sql, Object[] values) {
9 PreparedStatement ps = null;
10 ResultSet res = null;
11 List<Map<String, String>> list = new ArrayList<>();
12 getConnection();
13 try {
14 //创建语句对象
15 ps = conn.prepareStatement(sql);
16 //为ps中的？设置值
17 if (values != null && values.length > 0) {
18 for (int i = 0; i < values.length; i++) {
19 ps.setObject(i + 1, values[i]);
20 }
21 }
22 // 执行查询操作
23 res = ps.executeQuery();
24 //获得结果集中所有的列的信息
25 ResultSetMetaData metaData = res.getMetaData();
26 // 获取到列的总数
27 int columnCount = metaData.getColumnCount();
28 while (res.next()) {
29 // 创建Map集合对象，用于存储一行数据
30 Map<String, String> map = new HashMap<>();
31 for (int i = 0; i < columnCount; i++) {
32 // 获得列名
33 String columnNames = metaData.getColumnName(i + 1);
34 // 获得列名指定的数据
35 String columnValues = res.getString(columnNames);
36 // 把数据放到map集合中
37 map.put(columnNames, columnValues);
38 }
39 list.add(map);
40 }
41 } catch (SQLException e) {
42 // TODO Auto-generated catch block
43 e.printStackTrace();
44 } finally {
45 if (res != null) {
46 try {
47 res.close();
48 } catch (SQLException e) {
49 // TODO Auto-generated catch block
50 e.printStackTrace();
51 }
52 }
53 if (ps != null) {
54 try {
55 ps.close();
56 } catch (SQLException e) {
57 // TODO Auto-generated catch block
58 e.printStackTrace();
59 }
60 }
61 }
62 return list;
63
64 }
完整代码
1 1 package com.newroad.xmlparsedbuitl;
2 2 import java.sql.Connection;
3 3 import java.sql.DriverManager;
4 4 import java.sql.PreparedStatement;
5 5 import java.sql.ResultSet;
6 6 import java.sql.ResultSetMetaData;
7 7 import java.sql.SQLException;
8 8 import java.util.ArrayList;
9 9 import java.util.HashMap;
10 10 import java.util.List;
11 11 import java.util.Map;
12 12 import org.dom4j.Document;
13 13 import org.dom4j.DocumentException;
14 14 import org.dom4j.Element;
15 15 import org.dom4j.io.SAXReader;
16 16
17 17 public class DBUtil {
18 18 private static String driver;
19 19 private static String url;
20 20 private static String user;
21 21 private static String password;
22 22 private static Connection conn = null;
23 23
24 24 // 解析xml文件 获取驱动 用户名 密码 由于不需要每次加载可以写在静态方法中
25 25 static {
26 26 parseXmlInfo();
27 27 }
28 28
29 29 // 创建连接
30 30 public static void getConnection() {
31 31 // 判断一下如果conn为空或者被关闭就开连接 节省资源
32 32 try {
33 33 if (conn == null || conn.isClosed()) {
34 34 // 加载驱动获取连接
35 35 Class.forName(driver);
36 36 conn = DriverManager.getConnection(url + "?characterEncoding=utf-8", user, password);
37 37 }
38 38 } catch (SQLException e) {
39 39 e.printStackTrace();
40 40 } catch (ClassNotFoundException e) {
41 41 // TODO Auto-generated catch block
42 42 e.printStackTrace();
43 43 }
44 44 }
45 45 /**
46 46 * 修改数据的方法
47 47 *
48 48 * @param sql
49 49 * @param values
50 sql语句中所有？的值
51 51 * @return 0表示修改失败，其他表示修改成功
52 52 */
53 53 public static int update(String sql, Object[] values) {
54 54 PreparedStatement ps = null;
55 55 ResultSet rs = null;
56 56 // 获取连接
57 57 getConnection();
58 58 try {
59 59 // 创建prepareStatement
60 60 ps = conn.prepareStatement(sql);
61 61 System.out.println(ps);
62 62 for (int i = 0; i < values.length; i++) {
63 63 ps.setObject(i + 1, values[i]);
64 64 }
65 65 System.out.println(ps);
66 66 // 执行修改语句返回受影响的行数
67 67 int num = ps.executeUpdate();
68 68 System.out.println(num);
69 69 } catch (SQLException e) {
70 70 e.printStackTrace();
71 71 } finally {
72 72 // 关闭资源
73 73 if (ps != null) {
74 74 try {
75 75 ps.close();
76 76 } catch (SQLException e) {
77 77 // TODO Auto-generated catch block
78 78 e.printStackTrace();
79 79 }
80 80 }
81 81 }
82 82 return 0;
83 83 }
84 84
85 85 /**
86 86 * 查询的方法
87 87 *
88 88 * @param sql
89 89 * @param values
90 90 * @return 查询到的数据
91 91 */
92 92 public static List<Map<String, String>> query(String sql, Object[] values) {
93 93 PreparedStatement ps = null;
94 94 ResultSet res = null;
95 95 List<Map<String, String>> list = new ArrayList<>();
96 96 getConnection();
97 97 try {
98 98 //创建语句对象
99 99 ps = conn.prepareStatement(sql);
100 100 //为ps中的？设置值
101 101 if (values != null && values.length > 0) {
102 102 for (int i = 0; i < values.length; i++) {
103 103 ps.setObject(i + 1, values[i]);
104 104 }
105 105 }
106 106 // 执行查询操作
107 107 res = ps.executeQuery();
108 108 //获得结果集中所有的列的信息
109 109 ResultSetMetaData metaData = res.getMetaData();
110 110 // 获取到列的总数
111 111 int columnCount = metaData.getColumnCount();
112 112 while (res.next()) {
113 113 // 创建Map集合对象，用于存储一行数据
114 114 Map<String, String> map = new HashMap<>();
115 115 for (int i = 0; i < columnCount; i++) {
116 116 // 获得列名
117 117 String columnNames = metaData.getColumnName(i + 1);
118 118 // 获得列名指定的数据
119 119 String columnValues = res.getString(columnNames);
120 120 // 把数据放到map集合中
121 121 map.put(columnNames, columnValues);
122 122 }
123 123 list.add(map);
124 124 }
125 125 } catch (SQLException e) {
126 126 // TODO Auto-generated catch block
127 127 e.printStackTrace();
128 128 } finally {
129 129 if (res != null) {
130 130 try {
131 131 res.close();
132 132 } catch (SQLException e) {
133 133 // TODO Auto-generated catch block
134 134 e.printStackTrace();
135 135 }
136 136 }
137 137 if (ps != null) {
138 138 try {
139 139 ps.close();
140 140 } catch (SQLException e) {
141 141 // TODO Auto-generated catch block
142 142 e.printStackTrace();
143 143 }
144 144 }
145 145 }
146 146 return list;
147 147
148 148 }
149 149
150 150 // 使用dom4j解析xml
151 151 private static void parseXmlInfo() {
152 152 // 创建saxreader对象
153 153 SAXReader saxReader = new SAXReader();
154 154 try {
155 155 // 加载xml文件
156 156 Document doc = saxReader.read(DBUtil.class.getResourceAsStream("/jdbc.xml"));
157 157 // 获得根元素
158 158 Element root = doc.getRootElement();
159 159 // 获得对应的元素的文本值
160 160 driver = root.elementText("driver");
161 161 url = root.elementText("url");
162 162 user = root.elementText("user");
163 163 password = root.elementText("password");
164 164
165 165 } catch (DocumentException e) {
166 166 // TODO Auto-generated catch block
167 167 e.printStackTrace();
168 168 }
169 169 }
170 170 /**
171 171 * 关闭资源的方法
172 172 */
173 173 public static void closeConnection() {
174 174 try {
175 175 if(conn != null && !conn.isClosed()) {
176 176 conn.close();
177 177 }
178 178 } catch (SQLException e) {
179 179 // TODO Auto-generated catch block
180 180 e.printStackTrace();
181 181 }
182 182 }
183 183
184 184 }
DBUtil