1.1 Spring相关jar包引入(共9个jar包)
首先是配置spring容器jar：(context（上下文字段），core（spring核心包），expression（spring表达式）,bean（生产和装配bean的工厂）,
common-logging（spring 中bean是从aprache引入的，所以要提供logging依赖）)：
a.spring核心容器图
、 b.spring核心容器jar支持
1.2 Spring JdbcTemplate 里面c3p0支持的 jar包引入
a.jdbc驱动引入
b.Spring jdbcTemplate的相关的jar引入
c.c3p0的相关的jar引入
2.数据库准备
Source Server : gg Source Host : localhost:3306 Source Database : spring_database Target Server Type : MYSQL File Encoding : 65001 Date: 2017-03-08 14:27:35 */ SET FOREIGN_KEY_CHECKS=0; -- ---------------------------- -- Table structure for t_user -- ---------------------------- DROP TABLE IF EXISTS `t_user`; CREATE TABLE `t_user` ( `_id` int(11) NOT NULL AUTO_INCREMENT, `username` varchar(50) DEFAULT NULL, `userpwd` varchar(32) DEFAULT NULL, PRIMARY KEY (`_id`) ) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8; -- ---------------------------- -- Records of t_user -- ---------------------------- INSERT INTO `t_user` VALUES (‘1‘, ‘jake‘, ‘123456‘); INSERT INTO `t_user` VALUES (‘2‘, ‘rose‘, ‘123456789‘); INSERT INTO `t_user` VALUES (‘3‘, ‘tom‘, ‘999‘);
3.编码测试
2.1 User的标准JavaBean设计
/**
* 标准JavaBean
* @author GGR
*
*/
public class User {
@Override
public String toString() {
// TODO Auto-generated method stub
return super.toString();
}
private Integer _id;//用户id
private String username;//用户名
private String userpwd;//用户密码
public User(){}
public User(String username,String userpwd){
this.username = username;
this.setUserpwd(userpwd);
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getUserpwd() {
return userpwd;
}
public void setUserpwd(String userpwd) {
this.userpwd = userpwd;
}
public Integer get_id() {
return _id;
}
public void set_id(Integer _id) {
this._id = _id;
}
}
2.2 普通方式使用c3p0连接池
a.1 直接在UserDao里面测试
import java.beans.PropertyVetoException;
import org.springframework.jdbc.core.JdbcTemplate;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class UserDao {
public static void main(String[] args) throws PropertyVetoException {
/**
* c3p0连接池数据源配置
* 1.创建dataSources连接池对象
* 2.初始化连接池的4项基本配置(4项基本配置是所有种类的连接池都必须配置的)
* a.驱动名称 DriverClass
* b.数据库地址 JdbcUrl
* c.用户名 User
* d.密码 Password
*/
ComboPooledDataSource dataSource = new ComboPooledDataSource();
dataSource.setDriverClass("com.mysql.jdbc.Driver");
dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/spring_database");
dataSource.setUser("root");
dataSource.setPassword("362427gg");
// 创建模板工具类
JdbcTemplate jdbcTemplate = new JdbcTemplate();
jdbcTemplate.setDataSource(dataSource);
jdbcTemplate.update("insert into t_user(username,userpwd)values(?,?)", "tom","999");
}
}
a.2. 测试结果
2.3 使用c3p0连接池结合Spring容器
a.1思路：将所有的对象创建和管理权交给spring的容器（IOC/DI）
在src下创建bean.xml文件：
<?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"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="com.mysql.jdbc.Driver"></property>
<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/spring_database"></property>
<property name="user" value="root"></property>
<property name="password" value="362427gg"></property>
</bean>
<bean id="jdbctemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
</beans>
a.2编写测试代码
package com.heima_jdbctemplate_c3p0;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
public class Testdamo {
@Test
public void demo(){
String xmlpath = "com/heima_jdbctemplate_c3p0/bean.xml";
ApplicationContext context = new ClassPathXmlApplicationContext(xmlpath);
JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbctemplate");
jdbcTemplate.update("insert into t_user(username,userpwd)values(?,?)", "tom","362427");
}
}
a.3测试结果
2.4 使用c3p0连接池结合Spring容器（使用JdbcDaoSupport+注解+properties配置文件完成UserDao的设计）
将配置信息直接写到spring的bean.xml显然不够灵活，我们需要将连接池配置信息写到properties文件里面，这样方便修改和维护。
a.1 UserDao设计
import java.util.List;
import org.springframework.jdbc.core.simple.ParameterizedBeanPropertyRowMapper;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
/**
* 用户操作dao
* @author GGR
* ParameterizedBeanPropertyRowMapper提供里数据库每行每个参数到bean对象每个属性的映射
*/
public class UserDao extends JdbcDaoSupport{
public List<User> getAll(){
return this.getJdbcTemplate().query("select* from t_user",ParameterizedBeanPropertyRowMapper.newInstance(User.class));
}
public User QuerybyId(Integer _id){
return this.getJdbcTemplate().queryForObject("select* from t_user where _id=?", ParameterizedBeanPropertyRowMapper.newInstance(User.class),_id);
}
}
a.2 jdbcinfo.properties相关配置
jdbc.driverClass=com.mysql.Driver jdbc.jdbcUrl=jdbc:mysql://localhost:3306/spring_database jdbc.user=root jdbc.password=362427gg
a.3 bean.xml相关配置
<?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"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!-- 配置数据源 -->
<context:property-placeholder location="classpath:com/heima_jdbctemplate_c3p0/jdbcInfo.properties"/>
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${jdbc.driverClass}"></property>
<property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
<property name="user" value="${jdbc.user}"></property>
<property name="password" value="${jdbc.password}"></property>
</bean>
<!-- 扫描含有注解的包 -->
<context:component-scan base-package="com.heima_jdbctemplate_c3p0"></context:component-scan>
<!-- 配置jdbctemplate实例 -->
<bean id="jdbctemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
</beans>
a.4测试代码
package com.heima_jdbctemplate_c3p0;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
public class Testdamo {
@Test
public void demo(){
String xmlpath = "com/heima_jdbctemplate_c3p0/bean.xml";
ApplicationContext context = new ClassPathXmlApplicationContext(xmlpath);
UserDao dao = (UserDao) context.getBean("userdao");
System.out.println(dao.getAll());
}
}
a.5测试结果
总结：这里只是c3p0连接池的简单使用，主要是为了和Spring进行整合。
时间： 2024-09-30 10:02:01