百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

Java EE核心框架实战:如何使用MyBatis实现CURD-2种数据库

ccwgpt 2024-09-18 12:24 45 浏览 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开发领域中最核心、最实用的开发技术,帮助读者全面提升开发技能。

相关推荐

如何让老师看完文章后还啧啧称奇?满分作文有框架,这3点是关键

历年来语文考试中,作文的分数都占着相当大的一个比例,同时作文也是最容易拉开差距的一个模块。别人拿满分,而你却只有20分左右,分数的差距就是这样拉开的。作文想拿很高的分数却是不容易,但不是完全不可能的事...

小学作文写作技巧和方法,万能公式框架法。家长收藏

小学语文老师用心整理,将写作框架编成万能公式。作文的写作是语文学习中的重要一环,从小学到初中再到高中,作文一直是语文考试中占分比重最高的部分。小学阶段的语文写作相对来说比较简单,主要是打基础,但是很多...

如何用爆款改写技巧提升文章吸引力结构重塑:打破原文框架悬念前

如何用爆款改写技巧提升文章吸引力?结构重塑:打破原文框架悬念前置法-在开头设置悬念或提出反常识的结论,吸引读者注意力。例如,将“接纳不完美是治愈的开始”改写为“天天逼自己当完美超人?别杠了!生活本就...

守护袁昆:是否有必要按框架去写文章,拍摄剪辑视频?

(文/守护袁昆)如今不管是写文章还是剪辑视频,越来越多的朋友喜欢用框架、用脚本,作为互联网创作者,我们是否有必要按框架去写文章,拍摄剪辑短视频呢?其实在内容创作过程中,是否使用框架始终是一个充满争议的...

揭秘!爆款文章的秘密:让读者无法抗拒的文章框架

说说我自己一开始写文章都会犯一个毛病,文章,通常是想到哪里,写到哪里,“管不住字儿”。这样往往会出现以下问题绊住我们继续写下去1、很容易,写着就跑偏了,最终出来的成品和最初的设想偏离很大2、会写得很慢...

想要写出逻辑清晰的文章,你需要掌握哪些写作结构

想要写出好文章,就必须要了解文章的结构和框架。一篇文章结构清晰,读者就很容易跟上作者的思路,看出文章的重点内容。如果你对新媒体的文章有进行过研究,你就会发现很多公众号的文章结构都是类似的。所以你需要掌...

写作结构拆解:从选题到框架,如何让文章说服力翻倍?

你有没有想过,为什么有些文章能轻松获得很高的阅读量,而你的文章却始终无人问津?其实,写出爆款文章并没有想象中那么难。关键在于选择一个吸引人的主题,并用一个清晰的写作框架,通过2-3个有力的子观点支撑...

申论怎么写?结构怎么弄?这篇文章是最基本的好文章框架

写作总被吐槽逻辑混乱?三步搭建框架法,新手也能写出漂亮文章

一、结构决定论:信息传递的桥梁写作者和读者之间始终存在一道隐形的鸿沟。作者脑海中的想法如同一棵枝繁叶茂的大树,但直接倾倒给读者时,往往只剩下零散的枝叶,信息在传达过程中的丢失,作者输出的和读者读到的不...

如何搭建文章框架:新手写作者很有必要看

#头条深一度-深度阅读计划#见面好呀,我是潼臻~37岁,边上班边带娃的二胎妈妈藏起生活里的琐碎,期望你我都能遇到更好的自己~~~~~~~~~~~~~~~~~~果然多读书是可以真切学习到有用的东西最近把...

模型上下文协议(MCP)的可视化向导

最近,模型上下文协议(MCP)引起了广泛关注。你一定听说过它。今天,让我们来了解一下它是什么。直观地说,MCP就像是AI应用的USB-C接口。正如USB-C提供了一种标准化的方式,用于将...

97个人放一页PPT!用对Smartart架构图直接开挂!

从讯飞出差回来的路上,在高铁上看到一条微博,关于红楼梦人物的思维导图:下面很多家长说,帮助很大,能帮助上学的孩子梳理清人物关系,我看了下,清楚是清楚,但真的不太好看!作为一名PPT博主,我就顺带在高...

技术架构规范与实践(二)架构设计示例

1.逻辑架构1.1领域概念1.2宏观应用架构1.3宏观流程1.4微服务拆分与分层2.技术架构3.开发架构3.1后端技术栈分类名称版本描述后端框架/组件JavaJdk8(openjdk:8u342)后...

倾斜柱模板安装加固

1、适用范围:呈梯形逐层向内侧倾斜的框架柱。2、工艺流程:定位放线-配模-校正梁位置-安装加固。3、工艺方法:(1)定位放线首先现场技术管理人员对每颗不同标高的梁底、梁中边线及200mm控制线进行平面...

地基与基础工程、主体工程节点构造

#去班味吧#桩头凿除环切法工艺说明:1、根据桩头预留长度(深入承台10cm)放样桩顶标高,施工人员根据测量结果在基桩上用红油漆标注环切线;2、在切割线以上部分桩底,人工用钢钎打入桩底约15cm,打入时...

取消回复欢迎 发表评论: