dbcp連接配接池配置詳解_【064】Spring中使用JDBCTemplate進行配置

Spring中使用JDBCTemplate進行配置

建立項目，導入如下jar包

1）添加dbcp資料庫 
 #mysql的驅動
driver=com.mysql.jdbc.Driver
#連接配接位址
url=jdbc:mysql://localhost:3306/spring_jdbc?useUnicode=true&characterEncoding=UTF-8
#連接配接使用者名
user=root
#連接配接密碼
password=123456
#初始化數量
initsize=5
#最大數量
maxsize=15
#最大空閑數
maxIdle=3
#最小空閑數
minIdle=1
           

2）導入資源檔案、配置dbcp連接配接池資料、配置 Spring 的 jdbcTemplate

在spring的配置檔案applicationContext.xml配置中添加：

<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"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-4.2.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.2.xsd">
        <!--指定注解掃描包路徑-->
  		<context:component-scan base-package="com.oak"/>
  	
      	<!-- 導入資源檔案 -->
 	  	<context:property-placeholder location="classpath:dbutil.properties"/>
 	  	
 	  	<!-- 配置dbcp連接配接池參數 -->
                <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
           destroy-method="close">
                    <property name="driverClassName" value="${driver}" />
                    <property name="url" value="${url}" />
                    <property name="username" value="${user}" />
                    <property name="password" value="${password}" />
                    <!-- 連接配接池啟動時的初始值 -->
                    <property name="initialSize" value="${initsize}" />
                    <!-- 連接配接池的最大值 -->
                    <property name="maxActive" value="${maxsize}" />
                    <!-- 最大空閑值。當經過一個高峰時間後，連接配接池可以慢慢将已經用不到的連接配接慢慢釋放一部分，一直減少到maxIdle為止 -->
                    <property name="maxIdle" value="${maxIdle}" />
                    <!-- 最小空閑值。當空閑的連接配接數少于閥值時，連接配接池就會預申請去一些連接配接，以免洪峰來時來不及申請 -->
                    <property name="minIdle" value="${minIdle}" />
                </bean>
                
                <!-- 配置 Spring 的 jdbcTemplate -->
                <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
                        <property name="dataSource" ref="dataSource"/>    
                </bean>
</beans>
           

3）建立資料庫資料

在資料庫spring_jdbc中建立一張資料表user:

CREATE TABLE `user` (
  `id` int(4) NOT NULL AUTO_INCREMENT,
  `name` varchar(15) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
           

4）在src下建立一個包com.oak.domain，在包中建立一個實體類User

public class User {
        //使用者id
        private Integer id;
        //使用者名稱
        private String name;
        //構造方法，getter，setter方法和toString()略寫
}
           

5）在src建立一個包com.oak.dao,在其中建立一個UserDao接口

public interface UserDao {
        /**
         * 根據id删除使用者
         * @param id
         */
        void delete(Integer id);
        /**
         * 根據id查找使用者
         * @param id
         * @return
         */
        User findById(Integer id);
        /**
         * 修改使用者資訊
         * @param user
         */
        void update(User user);
        /**
         * 增加使用者
         * @param user
         */
        void add(User user);
        /**
         * 查詢所有
         * @return
         */
        List<User> list();
}
           

6）在dao包下建立類UserRowMapper實作RowMapper接口

public class UserRowMapper implements RowMapper<User>{
        //rs為傳回結果集，以每行為機關封裝着
        @Override
        public User mapRow(ResultSet rs, int rowNum) throws SQLException {
                // rs 已經指向每一條資料，不需要自己調用 next，将rs指向資料 轉換 User對象
                User user=new User(
                                rs.getInt("id"),
                                rs.getString("name"));
                return user;
        }
}
           

7）在dao包下建立一個UserDaoImpl實作UserDao接口

@Repository
public class UserDaoImpl implements UserDao{
        @Autowired
        private JdbcTemplate jdbcTemplate;
        
        public JdbcTemplate getJdbcTemplate() {
                return jdbcTemplate;
        }
        public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
                this.jdbcTemplate = jdbcTemplate;
        }
        @Override
        public void delete(Integer id) {
                jdbcTemplate.update("delete from user where id=?",new Object[]{id});
        }
        @Override
        public User findById(Integer id) {
                return jdbcTemplate.queryForObject("select * from user where id=?", new Object[]{id},
                                new UserRowMapper());
        }
        @Override
        public void update(User user) {
                jdbcTemplate.update("update user set name=? where id=?",new Object[]{user.getName(),user.getId()});
        }
        @Override
        public void add(User user) {
                jdbcTemplate.update("insert into user values(?,?)", new Object[]{null,user.getName()});
        }
        @Override
        public List<User> list() {
                return jdbcTemplate.query("select * from user", new UserRowMapper());
        }
}
           

8）在com.oak.test包中建立一個類TestJdbc，建立一個test01方法如下：

@Test

public void testJdbc(){

        ApplicationContext ctx=new ClassPathXmlApplicationContext("applicationContext.xml");

        UserDao userDao=ctx.getBean("userDaoImpl",UserDao.class);

        //測試增加

        //userDao.add(new User(null,"zs"));

        //測試查詢

        //System.out.println(userDao.list());

        //測試删除

        userDao.delete(1);

}