MyBatis学习总结（二）

Mybatis进行CRUD

之前已经配置了MyBatis的使用环境以及其它一切所需要的基础文件，但是一直没说这个东西究竟时怎么样来操作数据库的。上一次的总结最后的Test类就是干这件事情的。

基础方式

在测试类的方法中，显然是要读取conf.xml文件的，然后用这个IO流创建一个SqlSessionFactory（SqlSessionFactoryBuilder().build(reader)，build的第二个参数可以指定数据库环境，默认使用environments的default指定的）；用SqlSessionFactory的openSession方法还能构造一个SqlSession实例。

Reader reader=Resources.getResourceAsReader("conf.xml");
SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
SqlSession sqlSession=sqlSessionFactory.openSession();

讲了这么多，其实这个SqlSession实例就相当于JDBC的Connection，不过干的事情更多些：SqlSession不止是声明了数据库信息，它的创建所依据的那个conf.xml文件中还声明了映射文件，所以所有即将用到的sql语句都是SqlSession实例所直接能够使用的；而JDBC中所有的sql语句都要自己现场手写，不易管理、修改起来很不方便。

在Mapper.xml中，每一个sql语句都是由namespace和id来唯一标识。而这里增删改查的方式就是直接定位到每一个Mapper.xml中的语句来实现数据库操作，定位方法是直接将这两个东西弄成一个String：

String statement="shopkeeper.personMapper."+"queryAll";

增删改查是调用SqlSession实例的对应的方法，其中第一个参数必须是唯一标识statement，后继的参数如同Mapper.xml文件中的一样如果没有就不写，要有的话只能有一个（多个就封装成对象）；返回值稍作改变，Mapper.xml中无论返回值有多少个，都只写一个的情况，但是Java语言不能这样，要视情况改变（其实全写List也行，反正原理都是从游标读，然后返回值的多少其实是取决于你调用的SqlSession的方法，例如selectOne和selectLst）：

Person person=sqlSession.selectOne(statement,1);
List<Person> persons=sqlSession.selectList(statement);
int count=sqlSession.insert(statement,person);
int count=sqlSession.delete(statement,3);
int count=sqlSession.update(statement,person);

由于我使用的事务方式是JDBC，增删改操作还是要commit的，做法为调用SqlSession.commit()方法。

完整的方法如下：

public static void queryPersonById() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();
    String statement="shopkeeper.personMapper.queryPersonById";

    Person person=sqlSession.selectOne(statement,1);

    System.out.println(person);
    sqlSession.close();
    reader.close();
}

public static void queryAllPerson() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();
    String statement="shopkeeper.personMapper."+"queryAll";

    List<Person> persons=sqlSession.selectList(statement);

    System.out.println(persons);
    sqlSession.close();
    reader.close();
}

public static void addPerson() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();
    String statement="shopkeeper.personMapper."+"addPerson";

    Person person=new Person(19,"刘茜元",3);
    int count=sqlSession.insert(statement,person);
    sqlSession.commit();

    System.out.println("增加了"+count+"个人");
    sqlSession.close();
    reader.close();
}

public static void deletePersonById() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();
    String statement="shopkeeper.personMapper."+"detelePersonById";

    int count=sqlSession.delete(statement,3);
    sqlSession.commit();

    System.out.println("删除了"+count+"个人");
    sqlSession.close();
    reader.close();
}

public static void updatePersonById() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();
    String statement="shopkeeper.personMapper."+"updatePerson";

    Person person=new Person();
    person.setId(3);
    person.setName("刘闹闹");
    person.setAge(19);
    int count=sqlSession.update(statement,person);
    sqlSession.commit();

    System.out.println("更新了"+count+"个人");
    sqlSession.close();
    reader.close();
}

mapper动态代理方式CRUD

也叫接口开发。

在基础方式中说JDBC不好时，点名批评了JDBC每一个sql语句都要手写，但是其实基础方式里面也是要手写每一个statement的，只不过是将sql语句简化为了namespace+id了。

但是我们要严于律己，仅仅做到这方面是远远不够的，最好能够达到直接调用方法就能指哪打哪。mapper动态代理就是干的这件事。

总的来说，Mapper动态代理的思路就是将Mapper.xml中的sql语句变成接口中的方法，约定之前的namespace成为接口名称，每一个id变成方法名，具体是怎么实现的就是MyBatis底层的事情了。

那么，这些接口就需要满足以下几个要求：

接口名为namespace；

方法名为id值；

输入的参数和mapper.xml的parameterType一致；

返回值如果是查询就必须和resultType一致，如果你想要得到增删改操作成功的结果数量，就可以写成int，如果不想要就写void。

有多个Mapper.xml文件就实现多个接口。匹配的过程是根据接口名找到mapper. xml文件，根据接口的方法名找到mapper. xml文件中的SQL标签。（那么问题来了，如果两个不同的mapper.xml中有id相同的sql语句怎么办？对应到java就是两个不同的接口有同名的方法）。

还有一个习惯是： SQL映射文件(mapper. xml)和接口放在同一个包中(注意修改conf. xml中加载mapper. xml文件的路径）。

执行

先得到接口的实例化对象：

personMapper personMapper =sqlSession.getMapper(personMapper.class);

再通过接口的实例化对象来调用其方法（返回值自取）：

int count=personMapper.addPerson(person);

最后增删改别忘了commit。

完整的方法如下：

public static void queryPersonById() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();

    personMapper personMapper =sqlSession.getMapper(personMapper.class);
    Person person=personMapper.queryPersonById(1);


    System.out.println(person);
    sqlSession.close();
    reader.close();
}

public static void queryPersonByIdWithConverter() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();

    personMapper personMapper =sqlSession.getMapper(personMapper.class);
    Person person=personMapper.queryPersonByIdWithConverter(1);


    System.out.println(person);
    sqlSession.close();
    reader.close();
}


public static void queryAllPerson() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();

    personMapper personMapper =sqlSession.getMapper(personMapper.class);
    List<Person> persons=personMapper.queryAll();

    System.out.println(persons);
    sqlSession.close();
    reader.close();
}

public static void addPerson() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();

    Person person=new Person(19,"刘茜元",13);
    personMapper personMapper =sqlSession.getMapper(personMapper.class);
    int count=personMapper.addPerson(person);
    sqlSession.commit();

    System.out.println("增加了"+count+"个人");
    sqlSession.close();
    reader.close();
}

public static void addPersonWithConverter() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();

    Person person=new Person(19,"刘茜元",13);
    personMapper personMapper =sqlSession.getMapper(personMapper.class);
    int count=personMapper.addPersonWithConverter(person);
    sqlSession.commit();

    System.out.println("增加了"+count+"个人");
    sqlSession.close();
    reader.close();
}

public static void deletePersonById() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();

    personMapper personMapper =sqlSession.getMapper(personMapper.class);
    int count=personMapper.detelePersonById(13);
    sqlSession.commit();

    System.out.println("删除了"+count+"个人");
    sqlSession.close();
    reader.close();
}

public static void updatePersonById() throws IOException {
    Reader reader=Resources.getResourceAsReader("conf.xml");
    SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);//可以通过build的第二参数指定数据库环境
    SqlSession sqlSession=sqlSessionFactory.openSession();

    personMapper personMapper =sqlSession.getMapper(personMapper.class);
    Person person=new Person();
    person.setId(13);
    person.setName("刘咯咯");
    person.setAge(19);
    int count=personMapper.updatePerson(person);
    sqlSession.commit();

    System.out.println("更新了"+count+"个人");
    sqlSession.close();
    reader.close();
}