【济南中心】JavaEE就业班同步笔记第一阶段：JavaWeb之JDBC - 黑马程序员技术交流社区

1.2.2 步骤分析：
【步骤一】：创建一个Java项目.
【步骤二】：引入mysql的驱动包.
【步骤三】：编写代码.
【步骤四】：完成CRUD的操作：
1.3 代码实现：
工具类的抽取：

[Java] 纯文本查看 复制代码

public class JDBCUtils {

/**

* 注册驱动的方法

*/

public static void loadDriver(){

try {

Class.forName("com.mysql.jdbc.Driver");

} catch (ClassNotFoundException e) {

e.printStackTrace();

}

}

/**

* 获得连接的方法

*/

public static Connection getConnection(){



Connection conn = null;

try {

loadDriver();

conn = DriverManager.getConnection("jdbc:mysql:///web_07","root", "123");

} catch (SQLException e) {

e.printStackTrace();

}

return conn;

}

/**

* 释放资源的方法

*/

public static void release(ResultSet rs,Statement stmt,Connection conn){

if (rs != null) {

try {

rs.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

rs = null;

}

if (stmt != null) {

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

stmt = null;

}

if (conn != null) {

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

conn = null;

}

}

public static void release(Statement stmt,Connection conn){

if (stmt != null) {

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

stmt = null;

}

if (conn != null) {

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

conn = null;

}

}

}

带有属性文件的工具类的抽取：
定义了一个属性文件:

[Java] 纯文本查看 复制代码

public class JDBCUtils {

private static final String driverClass;

private static final String url;

private static final String username;

private static final String password;

static {

Properties properties = null;

// 读取属性文件：使用Java中Properties的对象.

try{

InputStream is = new FileInputStream("src/jdbc.properties");

properties = new Properties();

properties.load(is);

}catch(Exception e){

e.printStackTrace();

}

driverClass = properties.getProperty("driverClass");

url = properties.getProperty("url");

username = properties.getProperty("username");

password = properties.getProperty("password");

}

/**

* 注册驱动的方法

*/

public static void loadDriver(){

try {

Class.forName(driverClass);

} catch (ClassNotFoundException e) {

e.printStackTrace();

}

}

/**

* 获得连接的方法

*/

public static Connection getConnection(){

Connection conn = null;

try {

loadDriver();

conn = DriverManager.getConnection(url, username, password);

} catch (SQLException e) {

e.printStackTrace();

}

return conn;

}



/**

* 释放资源的方法

*/

public static void release(ResultSet rs,Statement stmt,Connection conn){

if (rs != null) {

try {

rs.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

rs = null;

}

if (stmt != null) {

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

stmt = null;

}

if (conn != null) {

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

conn = null;

}

}



public static void release(Statement stmt,Connection conn){

if (stmt != null) {

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

stmt = null;

}

if (conn != null) {

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

// 垃圾回收尽快回收对象.

conn = null;

}

}

}

参见JDBCDemo2类:
1.4 总结：
1.4.1 JDBC的API:
【Connection】

* 正常的情况下结果集只能向下的.

2 案例二：使用连接池改造JDBC的工具类
2.1 需求：
传统JDBC的操作,对连接的对象销毁不是特别好.每次创建和销毁连接都是需要花费时间.可以使用连接池优化的程序.
* 在程序开始的时候,可以创建几个连接,将连接放入到连接池中.用户使用连接的时候,可以从连接池中进行获取.用完之后,可以将连接归还连接池.
2.2 分析:
2.2.1 技术分析：
【自定义连接池】（了解）
* SUN公司提供了一个连接池的接口.(javax.sql.DataSource).
* 定义一个连接池:实现这个接口.
* 使用List集合存放多个连接的对象.
【自定义连接池的代码】

[Java] 纯文本查看 复制代码

public class MyDataSource implements DataSource{

// 创建一个List集合用于存放多个连接对象.

private List<Connection> list = new ArrayList<Connection>();

// 在程序开始的时候，初始化几个连接,将连接存放到list中.

public MyDataSource() {

// 初始化3个连接:

for(int i=1;i<=3;i++){

Connection conn = JDBCUtils.getConnection();

list.add(conn);

}

}

@Override

// 获得连接的方法：

public Connection getConnection() throws SQLException {

if(list.size() <= 0){

for(int i=1;i<=3;i++){

Connection conn = JDBCUtils.getConnection();

list.add(conn);

} 

}

Connection conn = list.remove(0);

return conn;

}

// 归还连接的方法：

public void addBack(Connection conn){

list.add(conn);

}

...

}

【自定义连接池中问题及如何解决】

* 增强一个Java类中的某个方法有几种方式???
* 一种方式：继承的方式.
      * 能够控制这个类的构造的时候,才可以使用继承.
* 二种方式：装饰者模式方式.
      * 包装对象和被包装的对象都要实现相同的接口.
      * 包装的对象中需要获得到被包装对象的引用.
      ***** 缺点：如果接口的方法比较多,增强其中的某个方法.其他的功能的方法需要原有调用.
* 三种方式：动态代理的方式.
      * 被增强的对象实现接口就可以.
【继承和装饰者的案例】
/**
* 继承的方式增强一个类中某个方法:
*/

[Java] 纯文本查看 复制代码

class Man{

public void run(){

System.out.println("跑....");

}

}

[Java] 纯文本查看 复制代码

class SuperMan extends Man{

public void run(){

// super.run();

System.out.println("飞....");

}

}

/**
* 使用装饰者的方式完成类的方法的增强
*/

[Java] 纯文本查看 复制代码

interface Waiter{

public void server();

}

[Java] 纯文本查看 复制代码

class Waiteress implements Waiter{

@Override

public void server() {

System.out.println("服务...");

}

}

[Java] 纯文本查看 复制代码

class WaiteressWrapper implements Waiter{

private Waiter waiter;

public WaiteressWrapper(Waiter waiter) {

this.waiter = waiter;

}

@Override

public void server() {

System.out.println("微笑...");

// this.waiter.server(); 

} 

}

【使用装饰者模式增强Connection的close方法】

[Java] 纯文本查看 复制代码

public class MyConnection implements Connection{

private Connection conn;

private List<Connection> list;



public MyConnection(Connection conn,List<Connection> list) {

this.conn = conn;

this.list = list;

}

@Override

public void close() throws SQLException {

list.add(conn);

}

...

}

连接池的getConnection方法：

@Override

// 获得连接的方法：

public Connection getConnection() throws SQLException {

if(list.size() <= 0){

for(int i=1;i<=3;i++){

Connection conn = JDBCUtils.getConnection();

list.add(conn);

} 

}

Connection conn = list.remove(0);

MyConnection myConn = new MyConnection(conn, list);

return myConn;

}

【常见的开源的数据库连接池】：

【DBCP连接池的使用】
第一步：引入DBCP连接池的jar包.
第二步：编写DBCP代码：
* 手动设置参数:
* 配置文件设置参数:
【DBCP连接池的使用】

[Java] 纯文本查看 复制代码

@Test

/**

* 手动方式:

*/

public void demo1(){

Connection conn = null;

PreparedStatement stmt = null;

ResultSet rs = null;

BasicDataSource dataSource = new BasicDataSource();

dataSource.setDriverClassName("com.mysql.jdbc.Driver");

dataSource.setUrl("jdbc:mysql:///web_07");

dataSource.setUsername("root");

dataSource.setPassword("123");

try{

// 获得连接:

conn = dataSource.getConnection();

// 编写SQL:

String sql = "select * from category";

// 预编译SQL:

stmt = conn.prepareStatement(sql);

// 执行SQL:

rs = stmt.executeQuery();

while(rs.next()){

System.out.println(rs.getInt("cid")+""+rs.getString("cname"));

}

}catch(Exception e){

e.printStackTrace();

}finally{

JDBCUtils.release(rs,stmt, conn);

}

}

[HTML] 纯文本查看 复制代码

 @Test

/**

* 配置文件方式：

*/

public void demo2(){

Connection conn = null;

PreparedStatement stmt = null;

ResultSet rs = null;

Properties properties = new Properties();

try{

properties.load(new FileInputStream("src/dbcpconfig.properties"));

DataSource dataSource = BasicDataSourceFactory.createDataSource(properties);

// 获得连接:

conn = dataSource.getConnection();

// 编写SQL:

String sql = "select * from category";

// 预编译SQL:

stmt = conn.prepareStatement(sql);

// 执行SQL:

rs = stmt.executeQuery();

while(rs.next()){

System.out.println(rs.getInt("cid")+""+rs.getString("cname"));

}

}catch(Exception e){

e.printStackTrace();

}finally{

JDBCUtils.release(rs,stmt, conn);

}

}

【C3P0连接池的使用】
第一步：引入C3P0连接池的jar包.
第二步：编写代码：
* 手动设置参数:
* 配置文件设置参数：
【C3P0改造工具类】

[Java] 纯文本查看 复制代码

public class JDBCUtils2 {

private static final ComboPooledDataSource DATA_SOURCE =newComboPooledDataSource();

/**

* 获得连接的方法

*/

public static Connection getConnection(){

Connection conn = null;

try {

conn = DATA_SOURCE.getConnection();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return conn;

}

...

}

3 案例三：手动抽取一个DBUtils的工具类
3.1 需求：
每次进行JDBC的CURD的操作的时候，有很多的代码都是相似的.可以不可以抽取工具类.完成一些通用性的代码?
3.2 分析：
3.2.1 技术分析：
【JDBC的元数据MataData】（了解）-- 编写通用性较高的代码.

* 获得结果集元数据：ResultSet中getMeta()
【元数据的使用】

[Java] 纯文本查看 复制代码

@Test

/**

* 数据库元数据

*/

public void demo1(){

Connection conn = null;

conn = JDBCUtils2.getConnection();

// 获得数据库元数据:

try {

DatabaseMetaData metaData = conn.getMetaData();

System.out.println("获得驱动名称:"+metaData.getDriverName());

System.out.println("获得驱动URL:"+metaData.getURL());

System.out.println("获得用户名:"+metaData.getUserName());

// 获得表中的主键：

ResultSet rs = metaData.getPrimaryKeys(null, null, "category");

if(rs.next()){

String name = rs.getString("COLUMN_NAME");

System.out.println(name);

}

} catch (SQLException e) {

e.printStackTrace();

}

}

@Test

/**

* 参数元数据：

*/

public void demo2(){

Connection conn = null;

PreparedStatement stmt = null;

try{

conn = JDBCUtils2.getConnection();

String sql = "update category set cname = ? where cid = ?";

stmt = conn.prepareStatement(sql);

ParameterMetaData metaData = stmt.getParameterMetaData();

int count = metaData.getParameterCount();

System.out.println(count);

}catch(Exception e){ 

}

}

@Test

/**

* 结果集元数据：

*/

public void demo3(){

Connection conn = null;

PreparedStatement stmt = null;

ResultSet rs = null;

try{

conn = JDBCUtils2.getConnection();

String sql = "select * from category";

stmt = conn.prepareStatement(sql);

rs = stmt.executeQuery();

ResultSetMetaData metaData = rs.getMetaData();

int count = metaData.getColumnCount();

for(int i = 1;i<=count ;i++){

String name = metaData.getColumnName(i);

String type = metaData.getColumnTypeName(i);

System.out.println(name+type);

}

}catch(Exception e){ 

}

}