4、在MyJDBCUtils中加入Properties保存数据库的配置信息
2016-03-14 13:28
507 查看
1、为了程序更好的解耦合,在MyJDBCUtils中加入Properties保存数据库的配置信息.
2、db.properties文件的内容如下
4、利用MyJDBCUtils连接数据库的代码如下
2、db.properties文件的内容如下
driver=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/testdatabase username=root password=12343、MyJDBCUtils的代码如下
package com.jdbc.utils; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; public class MyJDBCUtils { // 为了程序的更好的解耦合,利用Properties文件保存连接Mysql的配置文件 private static Properties config = new Properties(); static { try { config.load(MyJDBCUtils.class.getClassLoader().getResourceAsStream( "db.properties")); Class.forName(config.getProperty("driver")); } catch (Exception e) { throw new ExceptionInInitializerError(e); } } public static Connection getConnection() { Connection conn = null; try { conn = DriverManager.getConnection(config.getProperty("url"), config.getProperty("username"), config.getProperty("password")); } catch (SQLException e) { throw new RuntimeException("获取连接Mysql数据库连接失败"); } return conn; } public static void release(Connection conn, Statement st, ResultSet rs) { if (rs != null) { try { rs.close(); } catch (Exception e) { throw new RuntimeException("ResultSet关闭异常"); } rs = null; } if (st != null) { try { st.close(); } catch (Exception e) { throw new RuntimeException("Statement关闭异常"); } st = null; } if (conn != null) { try { conn.close(); } catch (Exception e) { throw new RuntimeException("Connection关闭异常"); } conn = null; } } }
4、利用MyJDBCUtils连接数据库的代码如下
package com.jdbc.utils; import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; import org.junit.Test; public class TestMyJDBCUtils { @Test public void testMyJDBCUtils() { Connection conn = null; Statement st = null; ResultSet rs = null; try { conn = MyJDBCUtils.getConnection(); st = conn.createStatement(); rs = st.executeQuery("select * from user "); while (rs.next()) { int id = rs.getInt(rs.findColumn("id")); String uname = rs.getString(rs.findColumn("uname")); int age = rs.getInt(rs.findColumn("age")); // 遍历输出 System.out.println("id " + id + " " + "uname " + uname + " " + "age " + age + " "); } } catch (Exception e) { throw new RuntimeException(e); } } }
相关文章推荐
- SCCM2012R2之二安装SQL Server
- sql中distinct用法
- jdbc查询oracle数据库时出现未找到要求的 XXX 关键字可能原因
- AppAssure备份Windows平台Oracle数据库
- Xml数据导入MySQL,SQLite等数据库
- mysql
- 跟我一起学Microsoft SQL Server 2012 Internals(1.4)
- mysql创建表时,设置自增字段
- 用oracle自带的ssh脚本配置互信
- oracle ora-各种常见java.sql.SQLException归结
- EF初始化mysql数据库codefirst
- ef model 修改时 数据库更新
- SQL Server里面如何检查没有释放的游标
- mysql按照每天分组查询数据结果排序不是从1到31而是1后接10
- SQL Server certificate Encryption
- 12C-OCP升级1z-060-002
- MySQL——重置密码
- 关系型数据库的完整性---锁、 约束 、键、 索引
- GPG key retrieval failed: [Errno 14] Could not open/read file:///etc/pki/rpm-gpg/RPM-GPG-KEY-oracle
- DB理论--数据库技术构成