Spring+SpringMVC+MyBatis深入学习及搭建(一)之MyBatis的基础知识

public class JDBCTest {
  public static void main(String[] args) {
    Connection connection = null;
    // 预编译的Statement，使用预编译的Statement提高数据库性能
    PreparedStatement preparedStatement = null;
    ResultSet resultSet = null;
    try {
      // 加载数据库驱动
      Class.forName("com.mysql.jdbc.Driver");
      // 通过驱动管理类获取数据库链接
      connection = DriverManager.getConnection(
              "jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf-8",
              "root", "root");
      // 定义sql语句 ?表示占位符
      String sql = "select * from t_user where username = ?";
      //获取预处理statement
      preparedStatement = connection.prepareStatement(sql);
      // 设置参数，第一个参数为sql语句中参数的序号（从1开始），第二个参数为设置的参数值
      preparedStatement.setString(1, "王五");
      // 向数据库发出sql执行查询，查询出结果集
      resultSet = preparedStatement.executeQuery();
      // 遍历查询结果集
      while (resultSet.next()) {
        System.out.println(resultSet.getString("id") + " "+ resultSet.getString("username"));
      }
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      //释放资源
      if (resultSet != null) {
        try {
          resultSet.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
      if (preparedStatement != null) {
        try {
          preparedStatement.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
      if (connection != null) {
        try {
          connection.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
    }
  }
}

# Global logging configuration
#在开发的环境下，日志级别要设置成DEBUG，生产环境设置成info或error
log4j.rootLogger=DEBUG, stdout
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
  <!-- 和spring整合后 environments配置将废除-->
  <environments default="development">
    <environment id="development">
    <!-- 使用jdbc事务管理,事务控制由mybatis管理-->
      <transactionManager type="JDBC" />
    <!-- 数据库连接池,由mybatis管理-->
      <dataSource type="POOLED">
        <property name="driver" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf-8" />
        <property name="username" value="root" />
        <property name="password" value="root" />
      </dataSource>
    </environment>
  </environments>
<!-- 加载映射文件 -->
  <mappers>
    <mapper resource="sqlmap/User.xml"/>
  </mappers>
</configuration>

package joanna.yan.mybatis.entity;
import java.sql.Date;
public class User {
  //属性名称和数据库字段名称保持一致
  private int id;
  private String username;
  private Date birthday;
  private String sex;
  private String address;
  public User(String username, Date birthday, String sex, String address) {
    super();
    this.username = username;
    this.birthday = birthday;
    this.sex = sex;
    this.address = address;
  }
  public User(int id, String username, Date birthday, String sex,
      String address) {
    super();
    this.id = id;
    this.username = username;
    this.birthday = birthday;
    this.sex = sex;
    this.address = address;
  }
  public int getId() {
    return id;
  }
  public void setId(int id) {
    this.id = id;
  }
  public String getUsername() {
    return username;
  }
  public void setUsername(String username) {
    this.username = username;
  }
  public String getSex() {
    return sex;
  }
  public void setSex(String sex) {
    this.sex = sex;
  }
  public String getAddress() {
    return address;
  }
  public void setAddress(String address) {
    this.address = address;
  }
  public Date getBirthday() {
    return birthday;
  }
  public void setBirthday(Date birthday) {
    this.birthday = birthday;
  }
  @Override
  public String toString() {
    return "User [id=" + id + ", username=" + username + ", sex=" + sex
        + ", address=" + address + ", birthday=" + birthday + "]";
  }
}

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--namespace命名空间，作用就是对sql进行分类化的管理，理解为sql隔离
  注意：使用mapper代理开发时，namespace有特殊作用 -->
<mapper namespace="test">
  <!--在映射文件中配置很多sql语句 -->
  <!--需求：通过id查询用户表的记录 -->
  <!--id：标识映射文件中的sql，称为statement的id。将sql语句封装在mapperStatement的对象中，所有id称为Statement的id；
    parameterType：指定输入参数的类型，这里指定int型；
    #{}:表示一个占位符；
    #{id}:其中id表示接收输入的参数，参数名称就是id，如果输入参数是简单类型，#{}中的参数名可以任意，可以是value或其它名称；
    resultType：指定输出结果所映射的Java对象类型，select指定resultType表示将单条记录映射成Java对象。
   -->
  <select id="findUserById" parameterType="java.lang.Integer" resultType="joanna.yan.mybatis.entity.User">
    select * from user where id=#{id}
  </select>
</mapper>

<!-- 加载映射文件 -->
<mappers>
  <mapper resource="sqlmap/User.xml"/>
</mappers>

public class MybatisFirst {
  @Test
  public void findUserByIdTest(){
    //mybatis的配置文件
    String resource="SqlMapConfig.xml";
    InputStream inputStream=null;
    SqlSession sqlSession=null;
    try {
      inputStream=Resources.getResourceAsStream(resource);
      //1.创建会话工厂，传入mybatis的配置文件信息
      SqlSessionFactory factory=new SqlSessionFactoryBuilder().build(inputStream);
      //2.通过工厂得到SqlSession
      sqlSession=factory.openSession();
      //3.通过SqlSession操作数据库
      //参数一：映射文件中的statement的id，等于namespace+"."+statement的id；
      //参数二：指定和映射文件中所匹配的parameterType类型的参数；
      //sqlSession.selectOne结果是与映射文件所匹配的resultType类型的对象；
      //selectOne：查询一条结果
      User user=sqlSession.selectOne("test.findUserById", 1);
      System.out.println(user.toString());
    } catch (IOException e) {
      e.printStackTrace();
    }finally{
      if(sqlSession!=null){
        sqlSession.close();
      }
      if(inputStream!=null){
        try {
          inputStream.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }    
  }
}

<!--  
  需求：根据用户名称模糊查询用户信息，可能返回多条数据 
  resultType：指定的就是单条记录所映射的Java类型；
    ${}：表示拼接sql字符串，将接收到的参数内容不加任何修饰的拼接在sql中。使用${}拼接sql，可能会引起sql注入；
    ${value}：接收输入参数的内容，如果传入的是简单类型，${}中只能使用value
   -->
  <select id="findUserByName" parameterType="java.lang.String" resultType="joanna.yan.mybatis.entity.User">
    select * from user where username LIKE '%${value}%'
  </select>

@Test
  public void findUserByNameTest(){
    //mybatis的配置文件
    String resource="SqlMapConfig.xml";
    InputStream inputStream=null;
    SqlSession sqlSession=null;
    try {
      inputStream=Resources.getResourceAsStream(resource);
      //1.创建会话工厂，传入mybatis的配置文件信息
      SqlSessionFactory factory=new SqlSessionFactoryBuilder().build(inputStream);
      //2.通过工厂得到SqlSession
      sqlSession=factory.openSession();
      //3.通过SqlSession操作数据库
      //参数一：映射文件中的statement的id，等于namespace+"."+statement的id；
      //参数二：指定和映射文件中所匹配的parameterType类型的参数；
      //sqlSession.selectOne结果是与映射文件所匹配的resultType类型的对象；
      //list中的user和resultType类型一致
      List<User> list=sqlSession.selectList("test.findUserByName", "小明");
      System.out.println(list);
    } catch (IOException e) {
      e.printStackTrace();
    }finally{
      if(sqlSession!=null){
        sqlSession.close();
      }
      if(inputStream!=null){
        try {
          inputStream.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }    
  }

<!-- 
  需求：添加用户 
  parameterType:指定输入的参数类型是pojo（包括用户信息）；
  #{}：中指定pojo的属性名称，接收到pojo对象的属性值，mybatis通过ONGL（类似于struts2的OGNL）获取对象的属性值
   -->
  <insert id="insertUser" parameterType="joanna.yan.mybatis.entity.User">
    insert into user (username,sex,address,birthday) values (#{username},#{sex},#{address},#{birthday})
  </insert>

@Test
  public void insertUserTest(){
    //mybatis的配置文件
    String resource="SqlMapConfig.xml";
    InputStream inputStream=null;
    SqlSession sqlSession=null;
    try {
      inputStream=Resources.getResourceAsStream(resource);
      //1.创建会话工厂，传入mybatis的配置文件信息
      SqlSessionFactory factory=new SqlSessionFactoryBuilder().build(inputStream);
      //2.通过工厂得到SqlSession
      sqlSession=factory.openSession();
      User user=new User("yan",new Date(System.currentTimeMillis()),"女", "上海");
      //3.通过SqlSession操作数据库
      //参数一：映射文件中的statement的id，等于namespace+"."+statement的id；
      //参数二：指定和映射文件中所匹配的parameterType类型的参数；
      sqlSession.insert("test.insertUser",user);
      //提交事务
      sqlSession.commit();
      System.out.println(user.getId());
    } catch (IOException e) {
      e.printStackTrace();
    }finally{
      if(sqlSession!=null){
        sqlSession.close();
      }
      if(inputStream!=null){
        try {
          inputStream.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }    
  }

 <!-- 
  需求：添加用户 
  parameterType:指定输入的参数类型是pojo（包括用户信息）；
  #{}：中指定pojo的属性名称，接收到pojo对象的属性值，mybatis通过ONGL（类似于struts2的OGNL）获取对象的属性值
   -->
  <insert id="insertUser" parameterType="joanna.yan.mybatis.entity.User">
    <!-- 将insert插入的数据的主键返回到User对象中；
      select last_insert_id()：得到刚inser进去记录的主键值，只适用于自增主键；
      keyProperty：将查询到的主键值，设置到parameterType指定的对象的那个属性；
      order：select last_insert_id()的执行顺序，相对于insert语句来说它的执行顺序；
      resultType：指定select last_insert_id()的结果类型；
     -->
    <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
      select last_insert_id()
    </selectKey>
    insert into user (username,sex,address,birthday) values (#{username},#{sex},#{address},#{birthday})
  </insert>

  <!-- 
  需求：添加用户 
  parameterType:指定输入的参数类型是pojo（包括用户信息）；
  #{}：中指定pojo的属性名称，接收到pojo对象的属性值，mybatis通过ONGL（类似于struts2的OGNL）获取对象的属性值
   -->
  <insert id="insertUser" parameterType="joanna.yan.mybatis.entity.User"><!-- 
      使用mysql的uuid(),实现非自增主键的返回；
      执行过程：通过uuid()得到主键，将主键设置到user对象的id的属性中，其次，在inser执行时，从user对象中取出id属性值； 
    -->
      <selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String">
        select uuid()
      </selectKey>
      insert into user (id,username,sex,address,birthday) values (#{id},#{username},#{sex},#{address},#{birthday})   
  </insert>

<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String">
      SELECT 序列名.nextval()
    </selectKey>
    insert into user(id,username,birthday,sex,address) value(#{id},#{username},#{birthday},#{sex},#{address})

<!-- 需求：删除用户 -->
  <delete id="deleteUser" parameterType="java.lang.Integer">
    delete from user where id=#{id}
  </delete>
  <!-- 需求：更新用户 注意：id必须存在 -->
  <update id="updateUser" parameterType="joanna.yan.mybatis.entity.User">
    update user set username=#{username},sex=#{sex},address=#{address},birthday=#{birthday} where id=#{id}
  </update>

@Test
  public void deleteUserTest(){
    //mybatis的配置文件
    String resource="SqlMapConfig.xml";
    InputStream inputStream=null;
    SqlSession sqlSession=null;
    try {
      inputStream=Resources.getResourceAsStream(resource);
      //1.创建会话工厂，传入mybatis的配置文件信息
      SqlSessionFactory factory=new SqlSessionFactoryBuilder().build(inputStream);
      //2.通过工厂得到SqlSession
      sqlSession=factory.openSession();
      //3.通过SqlSession操作数据库
      //参数一：映射文件中的statement的id，等于namespace+"."+statement的id；
      //参数二：指定和映射文件中所匹配的parameterType类型的参数；
      sqlSession.delete("test.deleteUser",3);
      //提交事务
      sqlSession.commit();
    } catch (IOException e) {
      e.printStackTrace();
    }finally{
      if(sqlSession!=null){
        sqlSession.close();
      }
      if(inputStream!=null){
        try {
          inputStream.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
  }
  @Test
  public void updateUserTest(){
    //mybatis的配置文件
    String resource="SqlMapConfig.xml";
    InputStream inputStream=null;
    SqlSession sqlSession=null;
    try {
      inputStream=Resources.getResourceAsStream(resource);
      //1.创建会话工厂，传入mybatis的配置文件信息
      SqlSessionFactory factory=new SqlSessionFactoryBuilder().build(inputStream);
      //2.通过工厂得到SqlSession
      sqlSession=factory.openSession();
      User user=new User(2,"yan",new Date(System.currentTimeMillis()), "女", "上海");
      //3.通过SqlSession操作数据库
      //参数一：映射文件中的statement的id，等于namespace+"."+statement的id；
      //参数二：指定和映射文件中所匹配的parameterType类型的参数；
      //根据id更新用户
      sqlSession.update("test.updateUser",user);
      //提交事务
      sqlSession.commit();
    } catch (IOException e) {
      e.printStackTrace();
    }finally{
      if(sqlSession!=null){
        sqlSession.close();
      }
      if(inputStream!=null){
        try {
          inputStream.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
  }