Spring连接数据库的方式1：利用Spring实现bean属性setter方式注入

利用Spring实现bean属性setter方式注入

一、JDBCDataSource类封装了管理数据库连接的方法getConnection(), 

这个方法在执行之前需要数据库连接参数: 数据库驱动, 连接URL, 用户名和密码.

二、利用Spring配置文件applicationContext.xml配置bean, 并且setter参数注入JDBCDataSource的连接参数, 

这样Spring在创建JDBCDataSource对象以后就会自动化的调用setter方法注入数据库连接参数.

1.新建名为csdn.daliu_it.setter的web工程，

在该工程导入如图所示的6个jar包, 包括Spring API 和 mysql-connector-java-5.1.16-bin.jar。



2.创建被Spring管理的JDBCDataScorce类, 用于连接到数据库。

package com.daliu_it.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

/**
* JDBCDataSource类封装了管理数据库连接的方法getConnection(), 这个方法在执行之前需要数据库连接参数: 数据库驱动,
* 连接URL, 用户名和密码.
*
* @author Administrator
*
*/
public class JDBCDataSource {

private String driver;// 驱动
private String url;// 链接地址
private String user;// 用户名
private String pwd;// 密码

// 1.对应的get（） set（）方法
public String getDriver() {
return driver;
}

public void setDriver(String driver) {
this.driver = driver;
}

public String getUrl() {
return url;
}

public void setUrl(String url) {
this.url = url;
}

public String getUser() {
return user;
}

public void setUser(String user) {
this.user = user;
}

public String getPwd() {
return pwd;
}

public void setPwd(String pwd) {
this.pwd = pwd;
}

// 2.写一个链接方法
// 注意导入的是sql的包
/**
* 用于链接数据库
*
* @return
* @throws SQLException
*/
public Connection getConnection() throws SQLException {
Connection conn = DriverManager.getConnection(url, user, pwd);
return conn;
}

// 3.关闭链接
/**
* 用户关闭连接
*/

public void close(Connection conn) {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}

}


3.新建applicationContext.xml, 并且增加setter代码注入JDBC参数

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:jee="http://www.springframework.org/schema/jee"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jpa="http://www.springframework.org/schema/data/jpa"
xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa-1.3.xsd"
default-init-method="init" default-destroy-method="destroy">

<!-- setter注入 :利用Spring配置文件applicationContext.xml配置bean, 并且setter参数注入JDBCDataSource的连接参数,
这样Spring在创建JDBCDataSource对象以后就会自动化的调用setter方法注入数据库连接参数. -->
<bean id="dataSource" class="com.daliu_it.dao.JDBCDataSource">
<property name="driver" value="com.mysql.jdbc.Driver"></property>
<property name="url" value="jdbc:mysql://localhost:3306/csdn"></property>
<property name="user" value="root"></property>
<property name="pwd" value="123456"></property>
</bean>

</beans>

4.新建一个TestCase 类  用来测试用例。

package com.daliu_it.test;

import java.sql.Connection;
import java.sql.SQLException;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.daliu_it.dao.JDBCDataSource;

public class TestCase {

@Test
public void testJDBCDataSource() throws SQLException {

// 注意这里的区别，并不是直接创建这个对象然后调用方法来实现
// JDBCDataSource jdbc = new JDBCDataSource();
// jdbc.getConnection();

/*
* 利用Spring配置文件applicationContext.xml配置bean,
* 并且setter参数注入JDBCDataSource的连接参数,
* 这样Spring在创建JDBCDataSource对象以后就会自动化的调用setter方法注入数据库连接参数.
*/

// 1.测试一下Spring环境是否搭建好
String conf = "applicationContext.xml";
ApplicationContext ac = new ClassPathXmlApplicationContext(conf);
System.out.println(ac);

// 2.setter参数注入JDBCDataSource的连接参数
// Spring在创建JDBCDataSource对象以后就会自动化的调用setter方法注入数据库连接参数

//还需要通过getBean来获得JDBCDataSource对象
JDBCDataSource ds = ac.getBean("dataSource", JDBCDataSource.class);

Connection conn = ds.getConnection();
System.out.println(conn);
}
}


6.创建数据库的脚本。

create database csdn;
use csdn;
-- 创建用户表
CREATE TABLE USERS
(
ID INT(7) NOT NULL AUTO_INCREMENT,
NAME VARCHAR(50) ,
PWD VARCHAR(50),
PHONE VARCHAR(50) ,
PRIMARY KEY (id),
-- 登录用户名唯一约束
constraint name_unique unique(name)
);

-- 向数据库插入模拟数据
insert into Users (id, name, pwd, phone) values ( 1,'Tom', '123', '110');
insert into Users (id, name, pwd, phone) values (2,'Jerry', 'abc', '119');
insert into Users (id, name, pwd, phone) values ( 3,'Andy', '456', '112');

select * from users;