MyBatis创建存储过程的实例代码_动力节点Java学院整理
所需要用到的其他工具或技术:
项目管理工具: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学院整理,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持!