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

package com.bjpowernode.practice; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; /**  *  * 存储过程类  *  * @author Freud  *  */ public class StoreProcedureOperationClass {   /**    *    * 执行插入的存储过程    *    * @param id    * @param username    * @param password    * @param nickname    * @throws SQLException    */   public static void insertData(int id, String username, String password, String nickname) throws SQLException   {     Connection connection = DriverManager.getConnection("jdbc:default:connection");     PreparedStatement p =         connection.prepareStatement("INSERT INTO USER_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("INSERT VALUES (id=" + id + ",username=" + username + ",password=" + password + ",nickname="         + nickname + ")");     p.executeUpdate();     p.close();     connection.close();   } } 

CREATE PROCEDURE FREUD.INSERT_USER(IN THE_ID INTEGER,           IN THE_USERNAME VARCHAR(20), IN THE_PASSWORD VARCHAR(20), IN THE_NICKNAME VARCHAR(20))  PARAMETER STYLE JAVA MODIFIES SQL DATA LANGUAGE JAVA  EXTERNAL NAME 'com.bjpowernode.practice.StoreProcedureOperationClass.insertData';  在 ij 控制台中调用call sqlj.install_jar('C:/freud/Test_Store_Procedure.jar', 'FREUD.TEST_SPROCEDURE', 0);将 jar 包导入到 FREUD模式中，并命名为TEST_SPROCEDURE。

Maven Dependencies:<dependencies>     <dependency>       <groupId>org.mybatis</groupId>       <artifactId>mybatis</artifactId>       <version>3.2.7</version>     </dependency>     <dependency>       <groupId>junit</groupId>       <artifactId>junit</artifactId>       <version>4.9</version>       <scope>test</scope>     </dependency>     <dependency>       <groupId>org.apache.derby</groupId>       <artifactId>derby</artifactId>       <version>10.10.2.0</version>     </dependency>     <dependency>       <groupId>org.apache.derby</groupId>       <artifactId>derbyclient</artifactId>       <version>10.10.2.0</version>     </dependency>   </dependencies> 

test-mybatis-configuration.xml<?xml version="1.0" encoding="UTF-8" ?>  <!DOCTYPE configuration   PUBLIC "-//mybatis.org//DTD Config 3.0//EN"   "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration>   <properties>     <property name="driver" value="org.apache.derby.jdbc.ClientDriver" />     <property name="url"       value="jdbc:derby://localhost:1527/freud;create=true" />   </properties>   <environments default="development">     <environment id="development">       <transactionManager type="JDBC" />       <dataSource type="POOLED">         <property name="driver" value="${driver}" />         <property name="url" value="${url}" />       </dataSource>     </environment>   </environments>   <mappers>     <mapper resource="com/freud/practice/UserMapper.xml" />   </mappers> </configuration>  

package com.bjpowernode.practice; public class User {   private Integer id;   private String username;   private String password;   private String nickname;   public Integer getId()   {     return id;   }   public void setId(Integer id)   {     this.id = id;   }   public String getUsername()   {     return username;   }   public void setUsername(String username)   {     this.username = username;   }   public String getPassword()   {     return password;   }   public void setPassword(String password)   {     this.password = password;   }   public String getNickname()   {     return nickname;   }   public void setNickname(String nickname)   {     this.nickname = nickname;   } } 

<?xml version="1.0" encoding="UTF-8" ?>  <!DOCTYPE mapper   PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"   "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.bjpowernode.practice.UserMapper">    <!-- 查询 -->   <select id="getUser" resultType="com.bjpowernode.practice.User">     select *     from USER_TEST_TB   </select>      <!-- 调用插入的存储过程 -->   <insert id="insertUser" statementType="CALLABLE">     CALL FREUD.INSERT_USER(#{id},#{username},#{password},#{nickname})   </insert> </mapper>  

package com.bjpowernode.practice; import java.util.List; public interface UserMapper {   public List<User> getUser();   public void insertUser(User user);  } 

package com.bjpowernode.practice; import java.io.InputStream; import java.text.MessageFormat; import java.util.List; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder; import org.junit.Before; import org.junit.Test; public class TestMyBatis {   private String source;   private InputStream inputStream;   private SqlSessionFactory sqlSessionFactory;   @Before   public void setUp()   {     /**      * 准备Mybatis运行环境      */     source = "test-mybatis-configuration.xml";     inputStream = TestMyBatis.class.getClassLoader().getResourceAsStream(source);     sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);   }   @Test   public void testInsert()   {     try     {       // 获取Session连接       SqlSession session = sqlSessionFactory.openSession();       // 获取Mapper       UserMapper userMapper = session.getMapper(UserMapper.class);       System.out.println("Test insert start...");       // 显示插入之前User信息       System.out.println("Before insert");       this.printUsers(userMapper.getUser());       // 执行插入       userMapper.insertUser(this.mockUser("FREU_INS_USER", "FREUD_INS_PASS", "FREUD_INS_NICK"));       // 提交事务       session.commit();       // 显示插入之后User信息       System.out.println("/r/nAfter insert");       this.printUsers(userMapper.getUser());       System.out.println("Test insert finished...");     }     catch (Exception e)     {       e.printStackTrace();     }   }   /**    *    * 组装一个User对象    *    * @return    */   public User mockUser(String username, String password, String nickname)   {     User user = new User();     user.setId(50);     user.setUsername(username);     user.setPassword(password);     user.setNickname(nickname);     return user;   }   /**    *    * 打印用户信息到控制台    *    * @param users    */   private void printUsers(final List<User> users)   {     int count = 0;     for (User user : users)     {       System.out.println(MessageFormat.format("==User[{0}]=================", ++count));       System.out.println("User Id: " + user.getId());       System.out.println("User UserName: " + user.getUsername());       System.out.println("User Password: " + user.getPassword());       System.out.println("User nickname: " + user.getNickname());     }   } }