@[TOC]

前言

学习完了和之后，那我们就可以进行数据库的操作了。

创建数据库

首先创建我们的数据库（这里我使用的是Mysql），为了演示方便，我这里简单的创建一个spring数据库，然后数据库有一个user用户表：

创建一个名为spring的数据库。

创建一个名为user的数据表，表包括id、email、name、password四个字段。

CREATE TABLE `user` (  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,  `email` varchar(255) DEFAULT NULL,  `name` varchar(255) DEFAULT NULL,  `password` varchar(255) DEFAULT NULL,  PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=11 DEFAULT CHARSET=latin1;复制代码

创建实体类

创建一个实体类和数据库的表相对应（模型用来储存要操作的数据）。

package cn.zhenta.www.service.impl.Entity;public class User {    int id;    String email;    String name;    String password;    public User(String email, String name, String password){        this.email = email;        this.name = name;        this.password = password;    }    public int getId(){        return id;    }    public void setId(int id) {        this.id = id;    }    public String getEmail(){        return email;    }    public void setEmail(String email){        this.email = email;    }    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;    }}复制代码

模型中的成员属性

id、

email、

name、

password分别对应数据表user的

字段，为每个成员属性添加

getter和

setter方法，实现对成员属性的操作。

数据访问对象（DAO）模式

DAO（data access object），数据库访问对象，主要的功能就是用于惊险数据库操作的。

UserDao接口

package cn.zhenta.www.service.impl.Dao;import cn.zhenta.www.service.impl.Entity.User;public interface UserDao {    public void inSert(User User);}复制代码

抽象了User的操作，即User可以进行

插入操作（inSert）。

UserDao接口的实现

package cn.zhenta.www.service.impl.Dao.impl;import cn.zhenta.www.service.impl.Dao.UserDao;import cn.zhenta.www.service.impl.Entity.User;import javax.sql.DataSource;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.SQLException;public class UserDaoImpl implements UserDao {    private DataSource dataSource;    public void setDataSource(DataSource dataSource){        this.dataSource = dataSource;    }    public void inSert(User user){        String sql = "INSERT INTO `spring`.`user` (`email`, `name`, `password`) VALUES (?, ?,?)";        Connection conn = null;        try{            conn = dataSource.getConnection();            PreparedStatement ps = conn.prepareStatement(sql);            ps.setString(1, user.getEmail());            ps.setString(2, user.getName());            ps.setString(3, user.getPassword());            ps.executeUpdate();            ps.close();        }catch(SQLException e){            throw new RuntimeException(e);        }finally {            if (conn != null) {                try {                    conn.close();                } catch (SQLException e) {}            }        }    }}复制代码

这里直接用了传统的JDBC，没有使用Spring的JdbcTemplate或者别的ORM框架。

private DataSource dataSource;这里对

数据源配置

这里为了方便直接使用了

直连的数据源（）,也可以使用连接池的数据源。


            
         
    复制代码

其中name="dataSource"为向cn.zhenta.www.service.impl.Dao.impl.UserDaoImpl这个类名为dataSource成员属性注入一个id为dataSource（ref="dataSource"）的Bean（通过setter方法即setDataSource），也就是

这样在UserDao的实现类UserDaoImpl就能完成了数据源的装配了。

装配Bean

package cn.zhenta.www.service.impl.Config;import org.springframework.context.annotation.ComponentScan;import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.ImportResource;@Configuration@ImportResource(locations = {
   "Spring-Datasource.xml"})@ComponentScan(basePackages = {
   "cn.zhenta.www.service.impl"})public class Config {}复制代码

@Configuration声明这个是配置类，@ImportResource装配xml配置文件（Spring-Datasource.xml为直连数据源的配置文件），@ComponentScan开启组件扫描。

测试类

package cn.zhenta.www.service.impl.TestC;import cn.zhenta.www.service.impl.Dao.UserDao;import cn.zhenta.www.service.impl.Entity.User;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;@ContextConfiguration(classes = cn.zhenta.www.service.impl.Config.Config.class)@RunWith(SpringJUnit4ClassRunner.class)public class TestC {    @Autowired    UserDao userDao;    @Test    public void dd(){        User user = new User("22", "xue8","22");        userDao.inSert(user);    }}复制代码

ContextConfiguration 指定Spring配置信息来源，UserDao userDAO引用UserDao接口，User user = new User("22", "xue8","22")创建一个User实体类中储存我们要保存的数据，userDAO.inSert(user)通过接口的实现类插入数据。

最后我们数据库成功插入了我们插入的数据。

欢迎加入JAVA学习群949419296，一起交流！