Spring框架中 配置c3p0連接池

 

開發准備：

1.導入jar包：

ioc基本jar

jdbcTemplate基本jar

c3p0基本jar

別忘了mysql數據庫驅動jar

原始程序代碼：不使用配置文件方式(IOC)生成訪問數據庫對象

package org.dao;
import java.beans.PropertyVetoException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;

public class Dao {
    public void add(){
        /*
        //使用spring框架中的jdbcTemplate完成數據庫的訪問
    
         //設置數據庫的信息
        DriverManagerDataSource dmds=new DriverManagerDataSource();
        dmds.setDriverClassName("com.mysql.jdbc.Driver");
        dmds.setUrl("jdbc:mysql://localhost:3306/c3p0jdbctemplate");
        dmds.setUsername("root");
        dmds.setPassword("jay571018");
        
        //創建JdbcTemplate對象  設置數據源
        JdbcTemplate jdbcTemplate=new JdbcTemplate(dmds);
        
        //調用方法  實現數據庫的訪問
        String sql="insert into User(name,password) values(?,?)";
        jdbcTemplate.update(sql,"joke",520);
        */
            
        //使用c3p0連接池  配置數據庫的信息  然后創建JdbcTemplate對象  設置數據源  完成對數據庫訪問
        ComboPooledDataSource datesourse=new ComboPooledDataSource();
        try {
            datesourse.setDriverClass("com.mysql.jdbc.Driver");
        } catch (PropertyVetoException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        datesourse.setJdbcUrl("jdbc:mysql://localhost:3306/c3p0jdbctemplate");
        datesourse.setUser("root");
        datesourse.setPassword("jay571018");
        //創建JdbcTemplate對象  設置數據源
        JdbcTemplate jdbcTemplate=new JdbcTemplate(datesourse);
        
        //調用方法  實現數據庫的訪問
        String sql="insert into User(name,password) values(?,?)";
        jdbcTemplate.update(sql,"joke",520);    
        System.out.println("增加了一條信息。。。。。。。");
    }
}

package org.service;
import org.dao.*;
public class Service {
    //想在service中調用dao對象的add方法   創建dao對象  生成對應的set方法 
    private Dao dao;
    
    //生成set方法  注入dao對象
    public void setDao(Dao dao){
        this.dao=dao;
    }
    public void add(){
        dao.add();
    }
}

package org.test;
import org.junit.Test;
import org.service.Service;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestDemo {
    @Test
    public void testDemo(){
        ApplicationContext ac=new ClassPathXmlApplicationContext("applicationContext.xml");
        Service s=(Service) ac.getBean("service");
        s.add();
    }
}

<?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:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    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
    http://www.springframework.org/schema/aop
    http://www.springframework.org/schema/aop/spring-aop.xsd
    http://www.springframework.org/schema/tx
    http://www.springframework.org/schema/tx/spring-tx.xsd">    
    <bean id="dao" class="org.dao.Dao"></bean>
    <bean id="service" class="org.service.Service">
        <property name="dao" ref="dao"></property>
    </bean>
</beans>

 

 

改進程序代碼：使用配置文件方式(IOC)生成訪問數據庫對象

需要注意的是：使用配置文件生成bean對象時，在的類中一定需要有屬性對應的set方法以及無參構造方法(不寫的話默認有一個無參構造)，否則無法完成注入，

兩者缺一不可，因為使用set注入的時候，spring先調用了構造方法實例化對象，然后才對對象中的屬性進行了注入。

另外IOC注入方式有兩種，一種set方式，另外一種是構造注入，構造注入的時候當然需要構造函數（有參數）。

 

package org.dao;
import java.beans.PropertyVetoException;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class Dao {
    private JdbcTemplate jdbcTemplate;
    
    //設置set方法  為了之后的注入
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
    public void add(){    
        String sql="insert into User(name,password) values(?,?)";
        jdbcTemplate.update(sql,"joke2",520);        
        System.out.println("增加了一條信息。。。。。。。");
    }
}

package org.service;
import org.dao.*;
public class Service {
    //想在service中調用dao對象的add方法   創建dao對象  生成對應的set方法 
    private Dao dao;
    
    //生成set方法  注入dao對象
    public void setDao(Dao dao){
        this.dao=dao;
    }    
    public void add(){
        dao.add();
    }
}

package org.test;
import org.junit.Test;
import org.service.Service;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestDemo {
    public static void main(String args[]){
        ApplicationContext ac=new ClassPathXmlApplicationContext("applicationContext.xml");
        Service s=(Service) ac.getBean("service");
        s.add();
    }
}

<?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:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    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
    http://www.springframework.org/schema/aop
    http://www.springframework.org/schema/aop/spring-aop.xsd
    http://www.springframework.org/schema/tx
    http://www.springframework.org/schema/tx/spring-tx.xsd">
    <!-- 創建連接池  配置連接池的屬性值 -->
    <bean id="ds" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/c3p0jdbctemplate"></property>
        <property name="user" value="root"></property>
        <property name="password" value="jay571018"></property>
    </bean>
    
    <!-- dao中注入jdbctemplate對象 -->
    <bean id="dao" class="org.dao.Dao">
        <property name="jdbcTemplate" ref="jdbctemplate"></property>
    </bean>                
    
    <!-- service中注入dao對象 -->
    <bean id="service" class="org.service.Service">
        <property name="dao" ref="dao"></property>
    </bean>
    
    <!-- 創建jdbctemplate對象  並且向其中注入連接池對象  dateSource是該對象中數據源的屬性 -->
    <bean id="jdbctemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="ds"></property>
    </bean>

</beans>

注入關系：

 

1.因為service類需要調用dao類中的方法，所以在service中生成了一個dao對象，並且存在set方法

    <!-- service中注入dao對象 -->
29     <bean id="service" class="org.service.Service">
30         <property name="dao" ref="dao"></property>
31     </bean>


2.在dao類中要對數據庫進行操作，所以創建jdbcTemplate對象，並且生成set方法

23     <!-- dao中注入jdbctemplate對象 -->
24     <bean id="dao" class="org.dao.Dao">
25         <property name="jdbcTemplate" ref="jdbctemplate"></property>
26     </bean>  

3.但是jdbcTemplate沒有設置數據源，所以我們導入了數據庫連接池，而且在配置文件中直接生成了c3p0連接池對象，就是用於jdbcTemplate對象的實例化

33     <!-- 創建jdbctemplate對象  並且向其中注入連接池對象  dateSource是該對象中數據源的屬性 -->
34     <bean id="jdbctemplate" class="org.springframework.jdbc.core.JdbcTemplate">
35         <property name="dataSource" ref="ds"></property>
36     </bean>

4. <!-- 創建連接池  配置連接池的屬性值 -->    

     <bean id="ds" class="com.mchange.v2.c3p0.ComboPooledDataSource">
17         <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
18         <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/c3p0jdbctemplate"></property>
19         <property name="user" value="root"></property>
20         <property name="password" value="jay571018"></property>
21     </bean>

以上就完成了對數據庫的訪問（向數據庫中插入了一條記錄），個人練習總結，請多指教。

 

 

-----------------------------------------

歡迎大家轉載，但請注明原創鏈接：http://www.cnblogs.com/Joke-Jay/p/6502507.html