01.MyBatis入门

MyBatis入门：

第一天接触Mybatis，总结一下入门案例的流程:

首先导入Mybatis的jar包和数据库的驱动包

1.创建数据表和实体类

2.创建一个表和实体类映射的xml配置文件，具体配置如下：

<?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是映射文件的一个唯一标识，用来定位是哪个映射文件 -->
<mapper namespace="com.offcn.entity.personMapper">
    <!-- id是一条sql语句的唯一标识,parameterType是sql语句中的参数类型 ，resultType是sql语句将要返回的结果的类型 -->
    <!-- 如果输入的类型是基本数据类型（八种基本数据类型 + string）则#{xxx}可以随意写，但是为了规范最好不要，如果不是基本数据类型则必须写实体类中的字段名 -->
  <select id="selectPersonById" parameterType="int" resultType="com.offcn.entity.Person">
    select * from Person where id = #{id}
  </select>
  <!-- sql语句后边不加分号 -->
  
  <insert id="insertPerson" parameterType="com.offcn.entity.Person">
      insert into Person (id,name,bir,address) value (#{id},#{name},#{bir},#{address})
  </insert>
  
  <delete id="deletePersonById" parameterType="int">
      delete from Person where id = #{id}
  </delete>
  
  <update id="updatePerson" parameterType="com.offcn.entity.Person">
      update person set name=#{name},bir=#{bir},address=#{address} where id = #{id}
  </update>
  
  <select id="selectPerson" resultType="com.offcn.entity.Person">
      select * from person
  </select>
  
</mapper>

3.编写全局配置文件conf.xml,包含数据库信息和映射文件信息,代码如下:

<?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>
    <!-- 环境的配置,可以配置多个,可以通过default该换id定位使用哪个环境,也可以通过 sessionFactory的第二个参数设置-->
  <environments default="development">
    <environment id="development">
        <!-- 配置事物的提交方式,一共有两种
            1.JDBC:利用JDBC的方式处理事务，需要手动提交(commit,rollback,close)
            2.MANAGED：将事务由其他组件托管（spring,jobss）,默认会关闭连接，如果想要自动关闭连接需要配置一个属性
             <property name="driver" value="false"/>
         -->
      <transactionManager type="JDBC"/>   <!-- 后边的斜杠不能省略 -->
     
      <!-- 数据源格式类型:
          1.POOLED:数据连接池模式
          2.UNPOOLED:传统的jdbc模式，每次都需要自己手动创建关闭
          3.JNDI:从tomcat中获取一个内置的数据库连接池
       -->
      <dataSource type="POOLED">
        <property name="driver" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/person?serviceTimeout=UTC"/>
        <property name="username" value="root"/>
        <property name="password" value="root"/>
      </dataSource>
    </environment>
  </environments>
  <mappers>
    <mapper resource="com/offcn/entity/personMapper.xml"/>
  </mappers>
</configuration>

3.写一个测试类，进行增删改查的测试,步骤如下：

package com.offcn.entity;

import java.io.IOException;
import java.io.Reader;
import java.util.Date;
import java.util.List;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class Test {
    public static void main(String[] args) throws IOException {
    //    selectPerosnById();
        //insertPerson();
        //deletePersonById();
        //updatePerson();
        selectPerson();
    }
    //根据id查询
    public static void selectPerosnById() throws IOException {
        //读取conf.xml 配置文件
        Reader reader = Resources.getResourceAsReader("conf.xml");
        //创建sqlSessionFactory
        SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        //创建session---> connection
        SqlSession session = sessionFactory.openSession();
        //statement ---> statement
        String sql = "com.offcn.entity.personMapper." + "selectPersonById";
        //查询一条数据
        Person person = session.selectOne(sql,1);
        //提交事务
        session.commit();
        System.out.println(person);
        //关闭连接
        session.close();
        
    }
    //增加一条数据
    public static void insertPerson() throws IOException {
        //读取conf.xml文件
        Reader reader = Resources.getResourceAsReader("conf.xml");
        //创建一个sqlSessionFactory
        SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        //创建一个session对象
        SqlSession session = sessionFactory.openSession();
        //定位sql语句
        String statement = "com.offcn.entity.personMapper." + "insertPerson";
        //执行sql语句
        Person person = new Person("李四",new Date(),"上海普陀");
        int count = session.insert(statement,person);
        //提交事务
        session.commit();
        System.out.println("增加"+count+"条数据");
        //关闭连接
        session.close();
    }
    //根据id删除一条数据
    public static void deletePersonById() throws IOException {
        //读取conf.xml文件
        Reader reader = Resources.getResourceAsReader("conf.xml");
        //获取sqlSessionFactory
        SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        //获取session对象
        SqlSession session = sessionFactory.openSession();
        //定位sql语句
        String statement = "com.offcn.entity.personMapper."+"deletePersonById";
        //执行sql语句
        int count = session.delete(statement,2);
        //提交事务
        session.commit();
        System.out.println("删除"+count+"条数据");
        //关闭连接
        session.close();
    }
    //更改数据
    public static void updatePerson() throws IOException {
        //读取conf.xml
        Reader reader = Resources.getResourceAsReader("conf.xml");
        //创建sqlSessionFactory
        SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        //创建sqlsession对象
        SqlSession session = sessionFactory.openSession();
        //定位sql
        String statement = "com.offcn.entity.personMapper." + "updatePerson";
        //执行sql语句
        Person person = new Person();
        person.setName("王五");
        person.setBir(new Date());
        person.setAddress("南京");
        person.setId(1);
        int count = session.update(statement,person);
        //提交事务
        session.commit();
        System.out.println("更改" + count +"条数据成功");
        //关闭连接
        session.close();
    }
    //查询所有数据
    public static void selectPerson() throws IOException {
        //读取conf.xml
        Reader reader = Resources.getResourceAsReader("conf.xml");
        //创建sqlSessionFactory
        SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        //创建sqlsession对象
        SqlSession session = sessionFactory.openSession();
        //定位sql
        String statement = "com.offcn.entity.personMapper." + "selectPerson";
        //执行sql语句
        List<Person> persons = session.selectList(statement);
        //提交事务
        session.commit();
        for (Person person : persons) {
            System.out.println(person);
        }
        
        //关闭连接
        session.close();
    }
}

到此就完成了一个Mybatis的入门程序。