spring對jdbc的支持

2019-11-06 06:25:57

字體：大中小

來源：轉載

供稿：網友

org.sPRingframework.jdbc.core.JdbcTemplate 是spring中對數據庫進行操作的核心類看API 文檔：這里寫圖片描述

再看該類的父類org.springframework.jdbc.support.Jdbc accessor 這里寫圖片描述所以在IOC容器中創建JdbcTemplate對象的時候有構造方法和屬性注入兩種方式用c3p0數據源 com.mchange.v2.c3p0.ComboPooledDataSource

dao層：

import java.io.Serializable;import org.springframework.jdbc.core.JdbcTemplate;import com.pactera.pojo.User;import com.pactera.util.UserRowMapper;public class UserDao{ private JdbcTemplate jdbcTemplate; public void setJdbcTemplate(JdbcTemplate jdbcTemplate){ this.jdbcTemplate = jdbcTemplate; } // 保存 public void save(User user){ String sql = "insert into user(name,age)values(?,?)"; jdbcTemplate.update(sql, user.getName(),user.getAge()); } //查詢 public User queryById(Serializable id){ String sql = "select * from user where id = ?"; User user = jdbcTemplate.queryForObject(sql,new UserRowMapper(), id); return user; }}

pojo類

package com.pactera.pojo;public class User { public String getName() { return name; } public void setName(String name) { this.name = name; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } private String name; private int age; @Override public String toString() { return "User [name=" + name + ", age=" + age + "]"; }}

數據庫字段和實體類的映射關系

package com.pactera.util;import java.sql.ResultSet;import java.sql.SQLException;import org.springframework.jdbc.core.RowMapper;import com.pactera.pojo.User;public class UserRowMapper implements RowMapper<User>{ //對于查詢的一行數據數據庫字段與實體類的屬性如何對應 @Override public User mapRow(ResultSet rs, int index) throws SQLException { User user = new User(); user.setAge(rs.getInt("age")); user.setName(rs.getString("name")); return user; }}

applicationContext.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:p="http://www.springframework.org/schema/p" 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="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="jdbcUrl" value="jdbc:MySQL://localhost:3306/test?useUnicode=true&characterEncoding=utf8"> </property> <property name="user" value="root"></property> <property name="passWord" value="root"></property> <property name="initialPoolSize" value="3"></property> <property name="maxPoolSize" value="50"></property> <property name="acquireIncrement" value="5"></property> </bean>  <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">  <constructor-arg name="dataSource" ref="dataSource"></constructor-arg>  </bean> <bean id="userDao" class="com.pactera.daoImpl.UserDao"> <property name="jdbcTemplate" ref="jdbcTemplate"></property> </bean></beans>

測試插入

@Test public void test(){ ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml"); UserDao userDao = ac.getBean("userDao",UserDao.class); User user = new User(); user.setAge(12); user.setName("張三"); userDao.save(user); }

數據庫結果: 這里寫圖片描述

查詢

@Test public void test2() throws Exception { ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml"); UserDao userDao = ac.getBean("userDao",UserDao.class); int id = 1; User user = userDao.queryById(id); System.out.println(user); }

結果這里寫圖片描述