什么是JDBC
JDBC代表Java Database Connectivity，它是提供一组JavaApi来访问关系数据库的Java程序。这些Apis可以使Java应用程序执行sql语句，能够与任何符合sql规范的数据库进行交互。
JDBC提供了一个灵活的框架来编写操作数据库的独立的应用程序，该程序能够运行在不同的平台上且不需修改，能够与不同的DBMS 进行交互。
Spring整合JDBC
一 导入需要的包
这里需要的包有如下：
|
<!--spring引入start--> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring.version}</version> </dependency> <!--spring AOP所要用到的包start--> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> <version>1.8.9</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> </dependency> <!--spring AOP所要用到的包end--> <!--spring jdbc所要用到的包start--> <dependency> <groupId>commons-dbcp</groupId> <artifactId>commons-dbcp</artifactId> <version>1.4</version> </dependency> <!--spring jdbc所要用到的包end--> <!--数据库连接的包--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.38</version> </dependency>
|
二 选择数据源
在beans.xml中创建dataSource数据源
|
<!-- 1.配置数据源 --> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <!-- 数据库驱动 --> <propertyname="driverClassName" value="{jdbc.driverClassName}"/> <!-- 连接数据库的url --> <property name="url" value="{jdbc.url}"/> <!-- 连接数据库的用户名 --> <property name="username" value="{jdbc.username}"/> <!-- 连接数据库的密码 --> <property name="password" value="{jdbc.password}"/> </bean>
|
创建数据源配置信息，创建一个jdbc.propertices文件来设置数据库的连接信息
|
validationQuery=SELECT 1 FROM DUAL jdbc.driverClassName=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/spring?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=UTC jdbc.username=root jdbc.password=123456
|
配置JDBC模板
|
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <!-- 默认必须使用数据源 --> <property name="dataSource" ref="dataSource"/> </bean>
|
定义id为accountDao的Bean
|
<bean id="accountDao" class="com.yujl.jdbc.dao.UserDaoImpl"> <!-- 将jdbcTemplate注入到accountDao实例中 --> <property name="jdbcTemplate" ref="jdbcTemplate"/> </bean>
|
三 DAO的实现
首先编写接口类，包括四个方法：增删改查
|
public interface UserDao { public void add(User user);
public void delete(int id);
public User review(int id);
public void update(User user , int id); }
|
接着实现这个接口并编写具体逻辑代码
|
public class UserDaoImpl implements UserDao { // 声明一个JdbcTmplate属性及其Setter方法 private JdbcTemplate jdbcTemplate;
//通过配置文件beans.xml public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } //对数据库进行添加操作 @Override public void add(User user) { String sql = "insert into user(name, password, age) values(?,?,?)"; jdbcTemplate.update(sql,user.getName(),user.getPassword(),user.getAge());
} // 删除操作 @Override public void delete(int id) { String sql = "delete from user where id = ?"; jdbcTemplate.update(sql,id);
} //根据ID查找信息 @Override public User review(int id) { String sql = "select * from user u where id = ?"; RowMapper<User> rowMapper = new BeanPropertyRowMapper<User>(User.class); return jdbcTemplate.queryForObject(sql,rowMapper,id);
} //根据ID对User进行更新 @Override public void update(User user, int id) { String sql = "updete user set name = ?,password = ?, age = ? where id = ?"; jdbcTemplate.update(sql,user.getName(),user.getPassword(),user.getAge(),id);
}
//创建一个内部类通过实现RowMapper来返回java对象 public class UserRowMapper implements RowMapper<User>{ @Override public User mapRow(ResultSet resultSet, int i) throws SQLException { User u = new User(); u.setName(resultSet.getString(2)); u.setPassword(resultSet.getString(3)); u.setAge(resultSet.getInt(4)); return u; } } }
|
四 User类
根据数据库创建相应的类，这里数据库是User，所以创建User类，具体代码如下
|
public class User { private int id; //id private String name; //名字 private String password; //密码 private int age; //年龄 public User(){}; public User(String name, String password, int age){ this.name = name; this.password = password; this.age = age; } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } @Override public String toString() { return "User{" + "id=" + id + ", name='" + name + '\'' + ", password='" + password + '\'' + ", age=" + age + '}'; } }
|
五 测试
到这里代码都差不多写完了，接下来测试一下
|
public class jdbcTest { public static void main(String[] args) { ApplicationContext applicationContext = new ClassPathXmlApplicationContext("/beans.xml"); //加载配置文件 UserDao userDao = (UserDao) applicationContext.getBean("accountDao"); //查询ID为4的用户信息 System.out.println(userDao.review(4));
//新增一条纪录 userDao.add(new User("liuyujiang","132456",15)); } }
|
运行结果如下：
总结
Spring的JDBC模块负责数据库资源管理和错误处理，大大简化了开发人员对数据库的操作，使得开发人员可以从繁琐的数据库操作中解脱出来。
