Java EE核心框架实战:如何使用MyBatis实现CURD-2种数据库
ccwgpt 2024-09-18 12:24 38 浏览 0 评论
MyBatis框架针对每一种数据库的操作都大同小异,本节将用示例的方式演示Oracle数据库的CURD操作。
1.准备开发环境
(1)创建数据表。
创建userinfo数据表,表结构如图1-23所示。
（2) 准备generatorConfig.xmli向配置文件。
(3)创建名称为mybatis_curd_oracle的Web项目。
（4)创建Userinfo.java实体类,实体类Userinfo.java类结构如图1-24所示。
（5）项目结构如图1-25所示。
(6)在Web项目mybatis_curd_oracle中的src路径下创建连接数据库的配置文件mybatis-config.xml,代码如下。
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"mybatis-3-config.dtd">
<configuration>
<environments default="development">
<environment id="development">
<transactionManager type="JDBC" />
<dataSource type="POOLED">
<property name="driver" value="oracle.jdbc.driver.OracleDriver" />
<property name="url" value="jdbc:oracle:thin:@localhost:1522:accp11g" />
<property name="username" value="ghy" />
<property name="password" value="123" />
</dataSource>
</environment>
</environments>
<mappers>
<mapper resource="userinfoMapping.xml" />
</mappers>
</configuration>其中userinfoMapping.xml映射文件内容如下。
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "mybatis-3-mapper.dtd">
<mapper namespace="mybatis.testcurd">
<insert id="insertUserinfo" parameterType="orm.Userinfo">
<selectKey resultType="java.lang.Long" keyProperty="id"
order="BEFORE">
select idauto.nextval from dual
</selectKey>
insert into
userinfo(id,username,password,age,insertDate) values(#{id},#{username},#{password},#{age},#{insertdate})
</insert>
<select id="getUserinfoById" parameterType="int" resultType="orm.Userinfo">
select * from
userinfo where id=#{id}
</select>
<delete id="deleteUserinfoById" parameterType="int">
delete from
userinfo where id=#{id}
</delete>
<select id="getAllUserinfo" resultType="orm.Userinfo">
select * from userinfo
</select>
<update id="updateUserinfoById" parameterType="orm.Userinfo">
update userinfo
set
username=#{username},password=#{password},age=#{age},insertDate=#{insertdate}
where id=#{id}
</update>
</mapper>需要特别说明的是，如果SQL语句有一些特殊符号，则必须使用如下的格式进行设计SQL语句。
<![CDATA[ sql语句 ]]>其中配置代码如下所示。
<selectKey resultType="java.lang.Long" keyProperty="id"
order="BEFORE">
select idauto.nextval from dual
</selectKey>标记<selectkey>的order="BEFORE"属性含义是select语句比insert语句先执行, resultType属性值为"java.lang.Long"是将序列返回的数字转成Long类型, keyProperty="id"的作用是将这个Long值放入parameterType的Userinfo的id属性里面。此段配置的主要功能是根据序列对象生成一个主键d值,并且此值还可以在代码中获取,也就是插入一条记录后使用程序代码就可以获取刚才插入记录的id值。
属性parameterType定义参数类型,属性resultType定义返回值的类型。继续创建测试用的Servlet对象,完整的项目结构如图1-26所示。
在图中可以发现src路径下有两个dtd文件,这是为了在开发XML配置或XML映射文件时实现代码自动提示功能。
2．创建获取SqlSession对象工具类
核心代码如下。
package dbtools;
import java.io.IOException;
import java.io.InputStream;
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 abstract class GetSqlSession {
public static SqlSession getSqlSession() throws IOException {
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder()
.build(inputStream); SqlSession sqlSsession = sqlSessionFactory.openSession();
return sqlSsession;
}
}3.插入多条记录
创建Servlet，核心代码如下。
public class insertUserinfo extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
Userinfo userinfo = new Userinfo();
userinfo.setUsername("高洪岩");
userinfo.setPassword("岩洪高");
userinfo.setAge(100L);
userinfo.setInsertdate(new Date());
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.insert("mybatis.testcurd.insertUserinfo", userinfo);
System.out.println(userinfo.getId());
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}变量SqlSession的insert方法的第1个参数是userinfoMapping.xml映射文件<insert>标签的id值,还要加上namespace命名空间的前缀,映射文件部分代码如下。
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "mybatis-3-mapper.dtd">
<mapper namespace="mybatis.testcurd">
<insert id="insertUserinfo" ……>在代码中可以看到获取已经插入数据表中记录的主键值。
执行Servlet后在控制台输出如图1-27所示。
Oracle数据库中的userinfo数据表内容如图1-28所示。
4. 根据id值查询记录
创建Servlet，核心代码如下。
public class getUserinfoById extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
Userinfo userinfo = sqlSession.selectOne(
"mybatis.testcurd.getUserinfoById", 7);
System.out.println(userinfo.getId());
System.out.println(userinfo.getUsername());
System.out.println(userinfo.getPassword());
System.out.println(userinfo.getAge());
System.out.println(userinfo.getInsertdate().toLocaleString());
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}程序运行后的效果如图1-29所示。
5. 查询所有记录
创建Servlet，核心代码如下。
public class getAllUserinfo extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
List<Userinfo> listUserinfo = sqlSession
.selectList("mybatis.testcurd.getAllUserinfo");
for (int i = 0; i < listUserinfo.size(); i++) {
Userinfo userinfo = listUserinfo.get(i);
System.out.println(userinfo.getId() + " "
+ userinfo.getUsername() + " " + userinfo.getPassword()
+ " " + userinfo.getAge() + " "
+ userinfo.getInsertdate().toLocaleString());
}
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}程序运行后打印出3条记录，如图1-30所示。
6. 更新记录
7. 创建Servlet，核心代码如下。
public class updateUserinfoById extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
Userinfo userinfo = sqlSession.selectOne(
"mybatis.testcurd.getUserinfoById", 7);
userinfo.setUsername("最新版高洪岩");
sqlSession.update("mybatis.testcurd.updateUserinfoById", userinfo);
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}程序运行后数据表userinfo中的记录被更新，如图1-31所示。
8. 删除记录
创建Servlet，核心代码如下。
public class deleteUserinfoById extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.delete("mybatis.testcurd.deleteUserinfoById", 6);
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}程序运行后，将id为6的记录删除了，如图1-32所示。
自此，针对Oracle数据库的CURD操作到此结束。
1.3.2 针对MySQL的CURD
本章节也将从零开始,使用MyBatis操作MySQL数据库。
1.准备开发环境
(1)在Eclipse中创建名称为mybatis_curd_mysql的项目。
(2)创建Userinfo.java实体类。
（3)创建mybatis-config.xml配置文件,代码如下。
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"mybatis-3-config.dtd">
<configuration>
<environments default="development">
<environment id="development">
<transactionManager type="JDBC" />
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql://localhost:3307/ghydb" />
<property name="username" value="root" />
<property name="password" value="123" />
</dataSource>
</environment>
</environments>
<mappers>
<mapper resource="userinfoMapping.xml" />
</mappers>
</configuration>(4)创建SQL映射文件userinfoMapping.xml，代码如下。
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "mybatis-3-mapper.dtd">
<mapper namespace="mybatis.testcurd">
<insert id="insertUserinfo" parameterType="orm.Userinfo"
useGeneratedKeys="true" keyProperty="id">
insert into
userinfo(username,password,age,insertDate)
values(#{username},#{password},#{age},#{insertdate})
</insert>
<select id="getUserinfoById" parameterType="int" resultType="orm.Userinfo">
select * from
userinfo where id=#{id}
</select>
<delete id="deleteUserinfoById" parameterType="int">
delete from
userinfo where id=#{id}
</delete>
<select id="getAllUserinfo" resultType="orm.Userinfo">
select * from userinfo
</select>
<update id="updateUserinfoById" parameterType="orm.Userinfo">
update userinfo
set
username=#{username},password=#{password},age=#{age},insertDate=#{insertdate}
where id=#{id}
</update>
</mapper>MySQL的主键是自增的,所以不需要序列这种机制。
2.增加一条记录并且返回主键值
创建Servlet对象,插入记录的代码和Oracle数据库对应的Servlet代码一致,运行后在控制台打印4条记录的主键D值,效果如图1-33所示。
数据表userinfo中的内容如图1-34所示。
3.其他业务方法的测试
其他的业务方法代码和操作Oracle数据库的大体一致,并且已经成功运行,详细代码请参看随书下载的源代码。
1.3.3 SQL映射文件中namespace命名空间的作用
当多个SQL映射文件中的id值一样时,在使用SqlSession操作数据库时会出现异常。
创建测试用的namespaceError项目,创建userinfoMapping.xml映射文件代码如下。
<mapper namespace="AAAAA">
<insert id="insertUserinfo" parameterType="orm.Userinfo">
<selectKey resultType="java.lang.Long" keyProperty="id"
order="BEFORE">
select idauto.nextval from dual
</selectKey>
insert into
userinfo(id,username,password,age)
values(#{id},#{username},#{password},#{age})
</insert>
</mapper>再创建名称为userinfoMappingZZZZZZZZ.xml映射文件,代码如下。
<mapper namespace="BBBBB">
<insert id="insertUserinfo" parameterType="orm.Userinfo">
<selectKey resultType="java.lang.Long" keyProperty="id"
order="BEFORE">
select idauto.nextval from dual
</selectKey>
insert into
userinfo(id,username,password,age)
values(#{id},#{username},#{password},#{age})
</insert>
</mapper>将这2个SQL映射文件使用<mapper>标签注册到mybatis-config.xml配置文件中,代码如下。
<configuration>
<environments default="development">
<environment id="development">
<transactionManager type="JDBC" />
<dataSource type="POOLED">
<property name="driver" value="oracle.jdbc.driver.OracleDriver" />
<property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl" />
<property name="username" value="y2" />
<property name="password" value="123" />
</dataSource>
</environment>
</environments>
<mappers>
<mapper resource="userinfoMapping.xml" />
<mapper resource="userinfoMappingZZZZZZZZ.xml" />
</mappers>
</configuration>在2个SQL映射文件中都有insert的id属性值为insertUserinfo的配置代码,执行如下Java代码。
public class insertUserinfo {
public static void main(String[] args) {
try {
Userinfo userinfo = new Userinfo();
userinfo.setUsername("高洪岩");
userinfo.setPassword("岩洪高");
userinfo.setAge(100L);
userinfo.setInsertdate(new Date());
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.insert("insertUserinfo", userinfo);
System.out.println(userinfo.getId());
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}执行后出现了异常，异常信息如下。
java.lang.IllegalArgumentException: insertUserinfo is ambiguous in Mapped Statements collection (try using the full name including the namespace, or rename one of the entries)异常信息提示insertUserinfo并不是确定的名字,是模糊的,可以尝试使用全名称的方式来调用此SQL映射,所谓的"全名称方式就是指sqlld之前写上namspace命名空间,对namespace命名空间的命名可以写上表的名称,或者是业务的名称,这样有助于区分重复的sqlld。
更改后的Java代码如下。
public class insertUserinfoOK {
public static void main(String[] args) {
try {
Userinfo userinfo = new Userinfo();
userinfo.setUsername("高洪岩");
userinfo.setPassword("岩洪高");
userinfo.setAge(100L);
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.insert("BBBBB.insertUserinfo", userinfo);
System.out.println(userinfo.getId());
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}执行insert()方法时在第1个参数加上了命名空间BBBBB ,使用小数点(.)做为间隔,再执行程序就不会出现异常了。
本文节选自《Java EE核心框架实战（第2版）》
本书基于MyBatis3+Hibernate5+Struts2+Spring4MVC+Spring4，融合了作者多年软件开发和培训的经验，面向实战，通过丰富且有参考价值的案例，展现了JavaEE开发领域中最核心、最实用的开发技术，帮助读者全面提升开发技能。
相关推荐
- 十分钟让你学会LNMP架构负载均衡（impala负载均衡）
-
业务架构、应用架构、数据架构和技术架构一、几个基本概念1、pv值pv值(pageviews):页面的浏览量概念：一个网站的所有页面，在一天内，被浏览的总次数。(大型网站通常是上千万的级别)2、u...
- AGV仓储机器人调度系统架构（agv物流机器人）
-
系统架构层次划分采用分层模块化设计，分为以下五层：1.1用户接口层功能：提供人机交互界面（Web/桌面端），支持任务下发、实时监控、数据可视化和报警管理。模块：任务管理面板：接收订单（如拣货、...
- 远程热部署在美团的落地实践（远程热点是什么意思）
-
Sonic是美团内部研发设计的一款用于热部署的IDEA插件，本文其实现原理及落地的一些技术细节。在阅读本文之前，建议大家先熟悉一下Spring源码、SpringMVC源码、SpringBoot...
- springboot搭建xxl-job(分布式任务调度系统)
-
一、部署xxl-job服务端下载xxl-job源码：https://gitee.com/xuxueli0323/xxl-job二、导入项目、创建xxl_job数据库、修改配置文件为自己的数据库三、启动...
- 大模型:使用vLLM和Ray分布式部署推理应用
-
一、vLLM：面向大模型的高效推理框架1.核心特点专为推理优化：专注于大模型（如GPT-3、LLaMA）的高吞吐量、低延迟推理。关键技术：PagedAttention：类似操作系统内存分页管理，将K...
- 国产开源之光【分布式工作流调度系统】:DolphinScheduler
-
DolphinScheduler是一个开源的分布式工作流调度系统，旨在帮助用户以可靠、高效和可扩展的方式管理和调度大规模的数据处理工作流。它支持以图形化方式定义和管理工作流，提供了丰富的调度功能和监控...
- 简单可靠高效的分布式任务队列系统
-
#记录我的2024#大家好，又见面了，我是GitHub精选君！背景介绍在系统访问量逐渐增大，高并发、分布式系统成为了企业技术架构升级的必由之路。在这样的背景下，异步任务队列扮演着至关重要的角色，...
- 虚拟服务器之间如何分布式运行?（虚拟服务器部署）
-
在云计算和虚拟化技术快速发展的今天，传统“单机单任务”的服务器架构早已难以满足现代业务对高并发、高可用、弹性伸缩和容错容灾的严苛要求。分布式系统应运而生，并成为支撑各类互联网平台、企业信息系统和A...
- 一文掌握 XXL-Job 的 6 大核心组件
-
XXL-Job是一个分布式任务调度平台，其核心组件主要包括以下部分，各组件相互协作实现高效的任务调度与管理：1.调度注册中心（RegistryCenter）作用：负责管理调度器（Schedule...
- 京东大佬问我,SpringBoot中如何做延迟队列?单机与分布式如何做?
-
京东大佬问我,SpringBoot中如何做延迟队列？单机如何做？分布式如何做呢？并给出案例与代码分析。嗯，用户问的是在SpringBoot中如何实现延迟队列，单机和分布式环境下分别怎么做。这个问题其实...
- 企业级项目组件选型(一)分布式任务调度平台
-
官网地址：https://www.xuxueli.com/xxl-job/能力介绍架构图安全性为提升系统安全性，调度中心和执行器进行安全性校验，双方AccessToken匹配才允许通讯；调度中心和执...
- python多进程的分布式任务调度应用场景及示例
-
多进程的分布式任务调度可以应用于以下场景：分布式爬虫：importmultiprocessingimportrequestsdefcrawl(url):response=re...
- SpringBoot整合ElasticJob实现分布式任务调度
-
介绍ElasticJob是面向互联网生态和海量任务的分布式调度解决方案，由两个相互独立的子项目ElasticJob-Lite和ElasticJob-Cloud组成。它通过弹性调度、资源管控、...
- 分布式可视化 DAG 任务调度系统 Taier 的整体流程分析
-
Taier作为袋鼠云的开源项目之一，是一个分布式可视化的DAG任务调度系统。旨在降低ETL开发成本，提高大数据平台稳定性，让大数据开发人员可以在Taier直接进行业务逻辑的开发，而不用关...
- SpringBoot任务调度:@Scheduled与TaskExecutor全面解析
-
一、任务调度基础概念1.1什么是任务调度任务调度是指按照预定的时间计划或特定条件自动执行任务的过程。在现代应用开发中，任务调度扮演着至关重要的角色，它使得开发者能够自动化处理周期性任务、定时任务和异...
欢迎 你 发表评论:
- 一周热门
- 最近发表
- 标签列表
-
- MVC框架 (46)
- spring框架 (46)
- 框架图 (58)
- flask框架 (53)
- quartz框架 (51)
- abp框架 (47)
- jpa框架 (47)
- laravel框架 (46)
- springmvc框架 (49)
- 分布式事务框架 (65)
- scrapy框架 (56)
- shiro框架 (61)
- 定时任务框架 (56)
- java日志框架 (61)
- JAVA集合框架 (47)
- grpc框架 (55)
- ppt框架 (48)
- 内联框架 (52)
- winform框架 (46)
- gui框架 (44)
- cad怎么画框架 (58)
- ps怎么画框架 (47)
- ssm框架实现登录注册 (49)
- oracle字符串长度 (48)
- oracle提交事务 (47)