MyBatis创建存储过程的实例代码_动力节点Java学院整理

2023-09-25 11:15:05 329

所需要用到的其他工具或技术:

项目管理工具:Maven

测试运行工具:Junit

数据库 :Derby

本节需要用到的有2部分，第一部分是如何在Derby中创建存储过程，第二部分是如何在Mybatis中调用存储过程

一.在Derby中创建存储过程

在Eclipse中创建一个新的普通Java项目命名为Test_Store_Procedure

在com.bjpowernode.practice包下创建一个Class命名为StoreProcedureOperationClass.class

packagecom.bjpowernode.practice;
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.PreparedStatement;
importjava.sql.SQLException;
/**
*
*存储过程类
*
*@authorFreud
*
*/
publicclassStoreProcedureOperationClass
{
/**
*
*执行插入的存储过程
*
*@paramid
*@paramusername
*@parampassword
*@paramnickname
*@throwsSQLException
*/
publicstaticvoidinsertData(intid,Stringusername,Stringpassword,Stringnickname)throwsSQLException
{
Connectionconnection=DriverManager.getConnection("jdbc:default:connection");
PreparedStatementp=
connection.prepareStatement("INSERTINTOUSER_TEST_TB(ID,USERNAME,PASSWORD,NICKNAME)VALUES(?,?,?,?)");
p.setInt(1,id);
p.setString(2,username);
p.setString(3,password);
p.setString(4,nickname);
System.out.println("INSERTVALUES(id="+id+",username="+username+",password="+password+",nickname="
+nickname+")");
p.executeUpdate();
p.close();
connection.close();
}
}

3.利用jar命令或者Eclipse工具导出到C:\freud\Test_Store_Procedure.jar

4.在ij命令行中声明存储过程

CREATEPROCEDUREFREUD.INSERT_USER(INTHE_IDINTEGER,
INTHE_USERNAMEVARCHAR(20),INTHE_PASSWORDVARCHAR(20),INTHE_NICKNAMEVARCHAR(20))
PARAMETERSTYLEJAVAMODIFIESSQLDATALANGUAGEJAVA
EXTERNALNAME'com.bjpowernode.practice.StoreProcedureOperationClass.insertData';
在ij控制台中调用callsqlj.install_jar('C:\freud\Test_Store_Procedure.jar','FREUD.TEST_SPROCEDURE',0);将jar包导入到FREUD模式中，并命名为TEST_SPROCEDURE。

6.在ij控制台中调用callSYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.database.classpath','FREUD.TEST_SPROCEDURE');将jar包加入到数据库classpath搜索路径中。

这样，Derby的存储过程就算创建完成了

二.在Mybatis中调用存储过程

MavenDependencies:


org.mybatis
mybatis
3.2.7


junit
junit
4.9
test


org.apache.derby
derby
10.10.2.0


org.apache.derby
derbyclient
10.10.2.0

Mybatis配置文件src/main/resource源目录下

test-mybatis-configuration.xml

User.java对象类(src/main/java/com/freud/practice目录下)

packagecom.bjpowernode.practice;
publicclassUser
{
privateIntegerid;
privateStringusername;
privateStringpassword;
privateStringnickname;
publicIntegergetId()
{
returnid;
}
publicvoidsetId(Integerid)
{
this.id=id;
}
publicStringgetUsername()
{
returnusername;
}
publicvoidsetUsername(Stringusername)
{
this.username=username;
}
publicStringgetPassword()
{
returnpassword;
}
publicvoidsetPassword(Stringpassword)
{
this.password=password;
}
publicStringgetNickname()
{
returnnickname;
}
publicvoidsetNickname(Stringnickname)
{
this.nickname=nickname;
}
}

UserMapper.xml Mapper文件（src/main/java/com.bjpowernode.practice目录下）






select*
fromUSER_TEST_TB



CALLFREUD.INSERT_USER(#{id},#{username},#{password},#{nickname})

UserMapper.javaMapper类（src/main/java/com.bjpowernode.practice目录下）

packagecom.bjpowernode.practice;
importjava.util.List;
publicinterfaceUserMapper
{
publicListgetUser();
publicvoidinsertUser(Useruser);

}

测试类TestMyBatis.java（src/test/java/com.bjpowernode.practice目录下）

packagecom.bjpowernode.practice;
importjava.io.InputStream;
importjava.text.MessageFormat;
importjava.util.List;
importorg.apache.ibatis.session.SqlSession;
importorg.apache.ibatis.session.SqlSessionFactory;
importorg.apache.ibatis.session.SqlSessionFactoryBuilder;
importorg.junit.Before;
importorg.junit.Test;
publicclassTestMyBatis
{
privateStringsource;
privateInputStreaminputStream;
privateSqlSessionFactorysqlSessionFactory;
@Before
publicvoidsetUp()
{
/**
*准备Mybatis运行环境
*/
source="test-mybatis-configuration.xml";
inputStream=TestMyBatis.class.getClassLoader().getResourceAsStream(source);
sqlSessionFactory=newSqlSessionFactoryBuilder().build(inputStream);
}
@Test
publicvoidtestInsert()
{
try
{
//获取Session连接
SqlSessionsession=sqlSessionFactory.openSession();
//获取Mapper
UserMapperuserMapper=session.getMapper(UserMapper.class);
System.out.println("Testinsertstart...");
//显示插入之前User信息
System.out.println("Beforeinsert");
this.printUsers(userMapper.getUser());
//执行插入
userMapper.insertUser(this.mockUser("FREU_INS_USER","FREUD_INS_PASS","FREUD_INS_NICK"));
//提交事务
session.commit();
//显示插入之后User信息
System.out.println("\r\nAfterinsert");
this.printUsers(userMapper.getUser());
System.out.println("Testinsertfinished...");
}
catch(Exceptione)
{
e.printStackTrace();
}
}
/**
*
*组装一个User对象
*
*@return
*/
publicUsermockUser(Stringusername,Stringpassword,Stringnickname)
{
Useruser=newUser();
user.setId(50);
user.setUsername(username);
user.setPassword(password);
user.setNickname(nickname);
returnuser;
}
/**
*
*打印用户信息到控制台
*
*@paramusers
*/
privatevoidprintUsers(finalListusers)
{
intcount=0;
for(Useruser:users)
{
System.out.println(MessageFormat.format("==User[{0}]=================",++count));
System.out.println("UserId:"+user.getId());
System.out.println("UserUserName:"+user.getUsername());
System.out.println("UserPassword:"+user.getPassword());
System.out.println("Usernickname:"+user.getNickname());
}
}
}

总结

以上所述是小编给大家介绍的MyBatis创建存储过程的实例代码_动力节点Java学院整理，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！

MyBatis创建存储过程的实例代码_动力节点Java学院整理

热门推荐

随机推荐