devbox
小蓝xlanll
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

【demo】IntelliJ IDEA + MyBatis + SQL Server_ntellij idea创建java项目,连接sql server数据库 demo

作者：小蓝xlanll | 2024-05-12 13:27:10

赞

踩

ntellij idea创建java项目,连接sql server数据库 demo

 

【SQL Server】

#1-> 新建数据库【TestDB】

#1->1 新建表【Products】

插入测试数据

#1->2 新建表【UserInfo】

插入测试数据

【IntelliJ IDEA】新建Java项目，项目结构如下

【新建lib文件】添加相应的jar包

loj4j : https://logging.apache.org/log4j/2.x/

mssql-jdbc：https://docs.microsoft.com/zh-cn/sql/connect/jdbc/using-the-jdbc-driver?view=sql-server-2017

mybatis：http://www.mybatis.org/mybatis-3/zh/index.html

配置jar包依赖【File】->【Project Structure】-> 【Modules】->【Dependencies】

选择项目下的【lib】文件夹

【配置DataSource】

【View】->【Tool Windows】->【Database】新建【SQL Server（Microsoft）】链接

填写相应的名称、链接数据库的名字，用户名及密码，默认端口号1433

链接成功后

【JavaBean文件】对应数据库中的每张表结构单独写一个Bean文件，对记录进行封装

  1. package com.mybatisdemo.beans;
  2.  
  3. public class ProductsBean {
  4.  
  5.     private int ProductID;
  6.     private String ProductName;
  7.     private double Price;
  8.     private String ProductDescription;
  9.  
  10.     public ProductsBean() {
  11.         super();
  12.     }
  13.  
  14.     public ProductsBean(int productID, String productName, double price, String productDescription) {
  15.         ProductID = productID;
  16.         ProductName = productName;
  17.         Price = price;
  18.         ProductDescription = productDescription;
  19.     }
  20.  
  21.     public ProductsBean(String productName, double price, String productDescription) {
  22.         ProductName = productName;
  23.         Price = price;
  24.         ProductDescription = productDescription;
  25.     }
  26.  
  27.     public int getProductID() {
  28.         return ProductID;
  29.     }
  30.  
  31.     public void setProductID(int productID) {
  32.         ProductID = productID;
  33.     }
  34.  
  35.     public String getProductName() {
  36.         return ProductName;
  37.     }
  38.  
  39.     public void setProductName(String productName) {
  40.         ProductName = productName;
  41.     }
  42.  
  43.     public double getPrice() {
  44.         return Price;
  45.     }
  46.  
  47.     public void setPrice(double price) {
  48.         Price = price;
  49.     }
  50.  
  51.     public String getProductDescription() {
  52.         return ProductDescription;
  53.     }
  54.  
  55.     public void setProductDescription(String productDescription) {
  56.         ProductDescription = productDescription;
  57.     }
  58.  
  59.     @Override
  60.     public String toString() {
  61.         return "ProductsBean{" +
  62.                 "ProductID=" + ProductID +
  63.                 ", ProductName='" + ProductName + '\'' +
  64.                 ", Price=" + Price +
  65.                 ", ProductDescription='" + ProductDescription + '\'' +
  66.                 '}';
  67.     }
  68. }

  1. package com.mybatisdemo.beans;
  2.  
  3. import java.util.Date;
  4.  
  5. public class UserInfoBean {
  6.  
  7.     private int ID;
  8.     private String username;
  9.     private String birthdate;
  10.     private String nationality;
  11.  
  12.     public UserInfoBean() {
  13.         super();
  14.     }
  15.  
  16.     public UserInfoBean(int id, String username, String birthdate, String nationality) {
  17.         this.ID = id;
  18.         this.username = username;
  19.         this.birthdate = birthdate;
  20.         this.nationality = nationality;
  21.     }
  22.  
  23.     public UserInfoBean(String username, String birthdate, String nationality) {
  24.         this.username = username;
  25.         this.birthdate = birthdate;
  26.         this.nationality = nationality;
  27.     }
  28.  
  29.     public int getID() {
  30.         return ID;
  31.     }
  32.  
  33.     public void setID(int id) {
  34.         this.ID = id;
  35.     }
  36.  
  37.     public String getUsername() {
  38.         return username;
  39.     }
  40.  
  41.     public void setUsername(String username) {
  42.         this.username = username;
  43.     }
  44.  
  45.     public String getBirthdate() {
  46.         return birthdate;
  47.     }
  48.  
  49.     public void setBirthdate(String birthdate) {
  50.         this.birthdate = birthdate;
  51.     }
  52.  
  53.     public String getNationality() {
  54.         return nationality;
  55.     }
  56.  
  57.     public void setNationality(String nationality) {
  58.         this.nationality = nationality;
  59.     }
  60.  
  61.     @Override
  62.     public String toString() {
  63.         return "UserInfoBean{" +
  64.                 "id=" + ID +
  65.                 ", username='" + username + '\'' +
  66.                 ", birthdate=" + birthdate +
  67.                 ", nationality='" + nationality + '\'' +
  68.                 '}';
  69.     }
  70. }

【Mapper文件】写对应的映射文件，针对每一个表，有对应的接口文件和xml配置文件

【需要注意的地方】

#1-> 接口文件Interface仅仅定义数据库操作函数，不实现具体

#2-> Mapper.xml文件编写的时候需要注意以下几点：

     #2->1 namespace需要对应到相应的接口文件

<mapper namespace="com.mybatisdemo.mapper.ProductsMapper">
<mapper namespace="com.mybatisdemo.mapper.UserInfoMapper">

     #2->2 对应每一个Bean文件对应一个ResultMap，property对应Bean文件中的属性，column对应数据库中的字段

  1. <resultMap id="ProductsDataMap" type="com.mybatisdemo.beans.ProductsBean">
  2.         <id property="ProductID" column="ProductID" javaType="java.lang.Integer"></id>
  3.         <result property="ProductName" column="ProductName" javaType="java.lang.String"></result>
  4.         <result property="Price" column="Price" javaType="java.lang.Double"></result>
  5.         <result property="ProductDescription" column="ProductDescription" javaType="java.lang.String"></result>
  6. </resultMap>

    #2->3 insert语句中需要注意ID号自动增长与非自动增长的区别

  1. <insert id="insertData" keyProperty="ProductID">
  2.         insert into Products (ProductID, ProductName, Price, ProductDescription)
  3.             values (#{ProductID},#{ProductName},#{Price},#{ProductDescription})
  4. </insert>
  1. <insert id="insertData" useGeneratedKeys="true" keyProperty="ID">
  2.         insert into UserInfo (username, birthdate, nationality)
  3.             values (#{username},#{birthdate},#{nationality})
  4. </insert>

 

  1. package com.mybatisdemo.mapper;
  2.  
  3. import com.mybatisdemo.beans.ProductsBean;
  4.  
  5. import java.util.ArrayList;
  6.  
  7. public interface ProductsMapper {
  8.  
  9.     //新增记录
  10.     public int insertData(ProductsBean product) throws Exception;
  11.  
  12.     //更新记录
  13.     public int updateData(ProductsBean product) throws Exception;
  14.  
  15.     //删除记录
  16.     public void deleteData(int id) throws Exception;
  17.  
  18.     //根据ID查询记录
  19.     public ProductsBean selectByID(int id) throws Exception;
  20.  
  21.     //查询所有记录
  22.     public ArrayList<ProductsBean> selectAll() throws Exception;
  23. }

注意：ProductsMapper.xml中的id号必须对应接口文件中的函数名称！ 

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org/DTD Mapper 3.0" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.mybatisdemo.mapper.ProductsMapper">
  4.     <!--自定义返回结果集-->
  5.  
  6.     <resultMap id="ProductsDataMap" type="com.mybatisdemo.beans.ProductsBean">
  7.         <id property="ProductID" column="ProductID" javaType="java.lang.Integer"></id>
  8.         <result property="ProductName" column="ProductName" javaType="java.lang.String"></result>
  9.         <result property="Price" column="Price" javaType="java.lang.Double"></result>
  10.         <result property="ProductDescription" column="ProductDescription" javaType="java.lang.String"></result>
  11.     </resultMap>
  12.  
  13.     <!--在各种标签中的id属性必须和接口中的方法名相同，id属性值必须唯一的，不能重复使用。
  14.         parameterType属性指明查询时使用的参数类型，resultType属性指明查询返回的结果集类型-->
  15.  
  16.     <!--useGeneratedKeys：（仅对insert有用）
  17.         这会告诉MyBatis使用JDBC的getGeneratedKeys方法来取出数据
  18.        （比如：像MySQL和SQLServer这样的数据库管理系统的自动递增字段）内部生成的主键。默认值：false。-->
  19.  
  20.     <!--keyProperty：（仅对 insert有用）
  21.         标记一个属性，MyBatis会通过getGeneratedKeys或者通过insert语句的selectKey子元素设置它的值。默认：不设置。 -->
  22.  
  23.     <!--#{}中的内容，为占位符，当参数为某个JavaBean时，表示放置该Bean对象的属性值-->
  24.  
  25.     <insert id="insertData" keyProperty="ProductID">
  26.         insert into Products (ProductID, ProductName, Price, ProductDescription)
  27.             values (#{ProductID},#{ProductName},#{Price},#{ProductDescription})
  28.     </insert>
  29.  
  30.     <update id="updateData" parameterType="com.mybatisdemo.beans.ProductsBean">
  31.         update Products set ProductName = #{ProductName}, Price = #{Price},
  32.             ProductDescription = #{ProductDescription} where ProductID = #{ProductID}
  33.     </update>
  34.  
  35.     <delete id="deleteData" parameterType="int">
  36.         delete from Products where ProductID = #{ProductID}
  37.     </delete>
  38.  
  39.     <select id="selectByID" parameterType="int" resultMap="ProductsDataMap">
  40.         select * from Products where ProductID = #{ProductID}
  41.     </select>
  42.  
  43.     <select id="selectAll" resultMap="ProductsDataMap">
  44.         select * from Products
  45.     </select>
  46.  
  47. </mapper>

  1. package com.mybatisdemo.mapper;
  2.  
  3. import com.mybatisdemo.beans.UserInfoBean;
  4.  
  5. import java.util.ArrayList;
  6.  
  7. public interface UserInfoMapper {
  8.  
  9.     //新增记录
  10.     public int insertData(UserInfoBean product) throws Exception;
  11.  
  12.     //更新记录
  13.     public int updateData(UserInfoBean product) throws Exception;
  14.  
  15.     //删除记录
  16.     public void deleteData(int id) throws Exception;
  17.  
  18.     //根据ID查询记录
  19.     public UserInfoBean selectByID(int id) throws Exception;
  20.  
  21.     //查询所有记录
  22.     public ArrayList<UserInfoBean> selectAll() throws Exception;
  23.  
  24. }

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org/DTD Mapper 3.0" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.mybatisdemo.mapper.UserInfoMapper">
  4.     <!--自定义返回结果集-->
  5.     <resultMap id="UserInfoDataMap" type="com.mybatisdemo.beans.UserInfoBean">
  6.         <id property="ID" column="ID" javaType="java.lang.Integer"></id>
  7.         <result property="username" column="username" javaType="java.lang.String"></result>
  8.         <result property="birthdate" column="birthdate" javaType="java.lang.String"></result>
  9.         <result property="nationality" column="nationality" javaType="java.lang.String"></result>
  10.     </resultMap>
  11.  
  12.     <!--在各种标签中的id属性必须和接口中的方法名相同，id属性值必须唯一的，不能重复使用。
  13.         parameterType属性指明查询时使用的参数类型，resultType属性指明查询返回的结果集类型-->
  14.  
  15.     <!--useGeneratedKeys：（仅对insert有用）
  16.         这会告诉MyBatis使用JDBC的getGeneratedKeys方法来取出数据
  17.        （比如：像MySQL和SQLServer这样的数据库管理系统的自动递增字段）内部生成的主键。默认值：false。-->
  18.  
  19.     <!--keyProperty：（仅对 insert有用）
  20.         标记一个属性，MyBatis会通过getGeneratedKeys或者通过insert语句的selectKey子元素设置它的值。默认：不设置。 -->
  21.  
  22.     <!--#{}中的内容，为占位符，当参数为某个JavaBean时，表示放置该Bean对象的属性值-->
  23.  
  24.     <insert id="insertData" useGeneratedKeys="true" keyProperty="ID">
  25.         insert into UserInfo (username, birthdate, nationality)
  26.             values (#{username},#{birthdate},#{nationality})
  27.     </insert>
  28.  
  29.     <update id="updateData" parameterType="com.mybatisdemo.beans.UserInfoBean">
  30.         update UserInfo set username = #{username}, birthdate = #{birthdate},
  31.         nationality = #{nationality} where ID = #{ID}
  32.     </update>
  33.  
  34.     <delete id="deleteData" parameterType="int">
  35.         delete from UserInfo where ID = #{ID}
  36.     </delete>
  37.  
  38.     <select id="selectByID" parameterType="int" resultMap="UserInfoDataMap">
  39.         select * from UserInfo where ID = #{ID}
  40.     </select>
  41.  
  42.     <select id="selectAll" resultMap="UserInfoDataMap">
  43.         select * from UserInfo
  44.     </select>
  45. </mapper>

【mybatisconfg.xml】注册mapper文件

 

  1. jdbc.driver = com.microsoft.sqlserver.jdbc.SQLServerDriver
  2. jdbc.url = jdbc:sqlserver://localhost:1433;useUnicode=true;databaseName=TestDB
  3. jdbc.username = sa
  4. jdbc.password = 180710

  1. <?xml version="1.0" encoding="utf-8" ?>
  2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
  3.  
  4. <configuration>
  5.     <!--引入外部配置文件-->
  6.     <properties resource="com/mybatisdemo/confg/sqlserver.properties"></properties>
  7.  
  8.     <!--设置SQL语句打印输出-->
  9.     <settings>
  10.         <setting name ="logImpl" value="STDOUT_LOGGING"/>
  11.     </settings>
  12.  
  13.     <!--配置mybatis运行环境-->
  14.     <environments default="mybatis">
  15.         <environment id="mybatis">
  16.             <!--type="JDBC"代表使用JDBC的提交和回滚来管理事务-->
  17.             <transactionManager type="JDBC"></transactionManager>
  18.             <!--mybatis提供了3种数据元类型，分别是：POOLEN、UPOOLED、JNDI-->
  19.             <!--POOLED表示JDBC数据源连接池-->
  20.             <!--UNPOOLED表示不支持数据源连接池-->
  21.             <!--JDNI表示外部数据源连接池-->
  22.             <dataSource type="POOLED">
  23.                 <property name="driver" value="${jdbc.driver}"></property>
  24.                 <property name="url" value="${jdbc.url}"></property>
  25.                 <property name="username" value="${jdbc.username}"></property>
  26.                 <property name="password" value="${jdbc.password}"></property>
  27.             </dataSource>
  28.         </environment>
  29.     </environments>
  30.  
  31.     <mappers>
  32.         <!-- 告知映射文件方式1，自动扫描包内的Mapper接口与配置文件
  33.             <package name="com/mybatis/mapper"/>-->
  34.         <!-- 告知映射文件方式2，一个个配置 -->
  35.         <mapper resource="com/mybatisdemo/mapper/ProductsMapper.xml"></mapper>
  36.         <mapper resource="com/mybatisdemo/mapper/UserInfoMapper.xml"></mapper>
  37.     </mappers>
  38.  
  39. </configuration>

【tools】新建SessionFactory类

  1. package com.demo.tools;
  2.  
  3. import org.apache.ibatis.io.Resources;
  4. import org.apache.ibatis.session.SqlSession;
  5. import org.apache.ibatis.session.SqlSessionFactory;
  6. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  7.  
  8. import java.io.Reader;
  9.  
  10. public class SessionFactory {
  11.  
  12.     public static SqlSessionFactory sessionFactory;
  13.  
  14.     static {
  15.         try{
  16.             //配置文件地址
  17.             String resources = "com/demo/confg/mybatisconfg.xml";
  18.             //使用MyBatis提供的Resources类加载mybatis的配置文件
  19.             Reader reader = Resources.getResourceAsReader(resources);
  20.             //构建sqlSession的工厂
  21.             sessionFactory = new SqlSessionFactoryBuilder().build(reader);
  22.  
  23.             System.out.println("静态创建了一次SqlSessionFactory!");
  24.         }catch (Exception e){
  25.             e.printStackTrace();
  26.         }
  27.     }
  28.  
  29.     //创建能执行映射文件中sql的sqlSession
  30.     public static SqlSession getSession()
  31.     {
  32.         return sessionFactory.openSession();
  33.     }
  34. }

【service】对应bean文件新建数据操作类

需要注意的是：session和mapper的初始化都需要单独写在每个函数内

  1. session = SessionFactory.getSession();
  2. mapper = session.getMapper(ProductsMapper.class);

最开始是放在构造函数里面的，导致程序报错：Executor was closed.

分析原因：因为单独的函数里写了session.close() ，执行下一个函数的时候会发现session已经关闭的情况下又被强迫需要打开执行，导致程序报错！

  1. package com.demo.service;
  2.  
  3. import com.demo.beans.ProductsBean;
  4. import com.demo.mapper.ProductsMapper;
  5. import com.demo.tools.SessionFactory;
  6. import org.apache.ibatis.session.SqlSession;
  7.  
  8. import java.util.ArrayList;
  9.  
  10. public class ProductsDataService {
  11.  
  12.     private SqlSession session;
  13.     private ProductsMapper mapper;
  14.  
  15.     public ProductsDataService() {
  16.         super();
  17.     }
  18.  
  19.     //新增记录
  20.     public void insertData(ProductsBean data){
  21.         
  22.         session = SessionFactory.getSession();
  23.         mapper = session.getMapper(ProductsMapper.class);
  24.         
  25.         try {
  26.             mapper.insertData(data);
  27.             System.out.println("[Products] 插入记录成功！");
  28.             System.out.println(data.toString());
  29.             session.commit();
  30.             System.out.println("session commit!");
  31.         }catch (Exception e){
  32.             e.printStackTrace();
  33.             session.rollback();
  34.         }finally {
  35.             session.close();
  36.             System.out.println("session close!");
  37.         }
  38.     }
  39.  
  40.     //批量插入记录
  41.     public void insertMultiData(ArrayList<ProductsBean> listBean){
  42.         
  43.         session = SessionFactory.getSession();
  44.         mapper = session.getMapper(ProductsMapper.class);
  45.         
  46.         int count = 0;
  47.         try {
  48.             count = mapper.insertMultiData(listBean);
  49.             session.commit();
  50.             System.out.println("session commit!");
  51.         }catch (Exception e){
  52.             e.printStackTrace();
  53.             session.rollback();
  54.         }finally {
  55.             session.close();
  56.             System.out.println("session close!");
  57.         }
  58.         if(count>0){
  59.             System.out.println("[Products] 多行插入记录成功！");
  60.             System.out.println("影响数目： " + count);
  61.         }
  62.         else
  63.             System.out.println("插入失败！" + count);
  64.     }
  65.  
  66.     //更新记录
  67.     public void updateData(ProductsBean data){
  68.         
  69.         session = SessionFactory.getSession();
  70.         mapper = session.getMapper(ProductsMapper.class);
  71.  
  72.         try{
  73.             mapper.updateData(data);
  74.             System.out.println("[Products] 更新记录成功！");
  75.             System.out.println(data.toString());
  76.             session.commit();
  77.             System.out.println("session commit!");
  78.         }catch (Exception e){
  79.             e.printStackTrace();
  80.             session.rollback();
  81.         }finally {
  82.             session.close();
  83.             System.out.println("session close!");
  84.         }
  85.     }
  86.  
  87.     //删除记录
  88.     public void deleteData(int id){
  89.         
  90.         session = SessionFactory.getSession();
  91.         mapper = session.getMapper(ProductsMapper.class);
  92.         
  93.         try{
  94.             mapper.deleteData(id);
  95.             System.out.println("[Products] 已经删除第"+id+"条记录！");
  96.             session.commit();
  97.             System.out.println("session commit!");
  98.         }catch (Exception e){
  99.             e.printStackTrace();
  100.             session.rollback();
  101.         }finally {
  102.             session.close();
  103.             System.out.println("session close!");
  104.         }
  105.     }
  106.  
  107.     //根据id查询记录
  108.     public void selectDataById(int id){
  109.         
  110.         session = SessionFactory.getSession();
  111.         mapper = session.getMapper(ProductsMapper.class);
  112.         
  113.         try{
  114.             ProductsBean data = mapper.selectByID(id);
  115.             System.out.println(data.toString());
  116.             session.commit();
  117.             System.out.println("session commit!");
  118.         }catch (Exception e){
  119.             e.printStackTrace();
  120.             session.rollback();
  121.         }finally {
  122.             session.close();
  123.             System.out.println("session close!");
  124.         }
  125.     }
  126.  
  127.     //查询所有的用户
  128.     public void selectAll(){
  129.         
  130.         session = SessionFactory.getSession();
  131.         mapper = session.getMapper(ProductsMapper.class);
  132.         
  133.         try{
  134.             ArrayList<ProductsBean> listdata = mapper.selectAll();
  135.             System.out.println("---------------Products selectAll--------------");
  136.             System.out.println("ProductID\t ProductName\t Price\t ProductDescription");
  137.             for (ProductsBean data:listdata)
  138.             {
  139. //                System.out.println(data.toString());
  140.                 System.out.println(data.getProductID()+"\t "+data.getProductName()+"\t "+data.getPrice()+"\t "+data.getProductDescription());
  141.             }
  142.             session.commit();
  143.             System.out.println("session commit!");
  144.         }catch (Exception e){
  145.             e.printStackTrace();
  146.             session.rollback();
  147.         }finally {
  148.             session.close();
  149.             System.out.println("session close!");
  150.         }
  151.     }
  152. }

  1. package com.demo.service;
  2.  
  3. import com.demo.beans.UserInfoBean;
  4. import com.demo.mapper.UserInfoMapper;
  5. import com.demo.tools.SessionFactory;
  6. import org.apache.ibatis.session.SqlSession;
  7.  
  8. import java.util.ArrayList;
  9.  
  10. public class UserInfoDataService {
  11.  
  12.     //新增记录
  13.     public void insertData(UserInfoBean data){
  14.         SqlSession session = SessionFactory.getSession();
  15.         UserInfoMapper mapper = session.getMapper(UserInfoMapper.class);
  16.  
  17.         try {
  18.             mapper.insertData(data);
  19.             System.out.println("[UserInfo] 插入记录成功！");
  20.             System.out.println(data.toString());
  21.             session.commit();
  22.             System.out.println("session commit!");
  23.         }catch (Exception e){
  24.             e.printStackTrace();
  25.             session.rollback();
  26.         }finally {
  27.             session.close();
  28.             System.out.println("session close!");
  29.         }
  30.     }
  31.  
  32.     //更新记录
  33.     public void updateData(UserInfoBean data){
  34.         SqlSession session = SessionFactory.getSession();
  35.         UserInfoMapper mapper = session.getMapper(UserInfoMapper.class);
  36.  
  37.         try{
  38.             mapper.updateData(data);
  39.             System.out.println("[UserInfo] 更新记录成功！");
  40.             System.out.println(data.toString());
  41.             session.commit();
  42.             System.out.println("session commit!");
  43.         }catch (Exception e){
  44.             e.printStackTrace();
  45.             session.rollback();
  46.         }finally {
  47.             session.close();
  48.             System.out.println("session close!");
  49.         }
  50.     }
  51.  
  52.     //删除记录
  53.     public void deleteData(int id){
  54.         SqlSession session = SessionFactory.getSession();
  55.         UserInfoMapper mapper = session.getMapper(UserInfoMapper.class);
  56.  
  57.         try{
  58.             mapper.deleteData(id);
  59.             System.out.println("[UserInfo] 已经删除第"+id+"条记录！");
  60.             session.commit();
  61.             System.out.println("session commit!");
  62.         }catch (Exception e){
  63.             e.printStackTrace();
  64.             session.rollback();
  65.         }finally {
  66.             session.close();
  67.             System.out.println("session close!");
  68.         }
  69.     }
  70.  
  71.     //根据id查询记录
  72.     public void selectDataById(int id){
  73.         SqlSession session = SessionFactory.getSession();
  74.         UserInfoMapper mapper = session.getMapper(UserInfoMapper.class);
  75.  
  76.         try{
  77.             UserInfoBean data = mapper.selectByID(id);
  78.             System.out.println(data.toString());
  79.             session.commit();
  80.             System.out.println("session commit!");
  81.         }catch (Exception e){
  82.             e.printStackTrace();
  83.             session.rollback();
  84.         }finally {
  85.             session.close();
  86.             System.out.println("session close!");
  87.         }
  88.     }
  89.  
  90.     //查询所有的用户
  91.     public void selectAll(){
  92.         SqlSession session = SessionFactory.getSession();
  93.         UserInfoMapper mapper = session.getMapper(UserInfoMapper.class);
  94.         try{
  95.             ArrayList<UserInfoBean> listdata = mapper.selectAll();
  96.             for (UserInfoBean data:listdata)
  97.             {
  98.                 System.out.println(data.toString());
  99.             }
  100.             session.commit();
  101.             System.out.println("session commit!");
  102.         }catch (Exception e){
  103.             e.printStackTrace();
  104.             session.rollback();
  105.         }finally {
  106.             session.close();
  107.             System.out.println("session close!");
  108.         }
  109.     }
  110. }

 【测试类】main.java文件

  1. package com.mybatisdemo.main;
  2.  
  3. import com.mybatisdemo.beans.ProductsBean;
  4. import com.mybatisdemo.beans.UserInfoBean;
  5. import com.mybatisdemo.service.ProductsDataService;
  6. import com.mybatisdemo.service.UserInfoDataService;
  7.  
  8. public class Main {
  9.  
  10.     public static void main(String[] args) {
  11. 	// write your code here
  12.  
  13.         //生成一个dataservice类辅助数据操作
  14.         ProductsDataService productsDataService = new ProductsDataService();
  15.  
  16.         //查询所有记录
  17.         productsDataService.selectAll();
  18.  
  19. //        //插入一行新记录
  20. //        ProductsBean product = new ProductsBean(2018,"fuyao",56.76,"同风而起，扶摇直上");
  21. //        productsDataService.insertData(product);
  22. //
  23. //        productsDataService.selectAll();
  24. //
  25. //        //更新记录
  26. //        product.setPrice(55.86);
  27. //        product.setProductDescription("扶风摇曳，自如纵横");
  28. //
  29. //        productsDataService.updateData(product);
  30. //
  31. //        productsDataService.selectAll();
  32. //
  33. //        //通过id查询记录
  34. //        productsDataService.selectDataById(2018);
  35. //        //删除记录
  36. //        productsDataService.deleteData(2018);
  37. //
  38. //        productsDataService.selectAll();
  39.  
  40.  
  41.         //生成一个dataservice类辅助数据操作
  42.         UserInfoDataService userInfoDataService = new UserInfoDataService();
  43.  
  44.         //查询所有记录
  45.         userInfoDataService.selectAll();
  46.  
  47. //        //插入一条新记录
  48. //        UserInfoBean userInfo = new UserInfoBean("彭于晏","1982-3-24","中国");
  49. //        userInfoDataService.insertData(userInfo);
  50. //
  51. //        userInfoDataService.selectAll();
  52. //
  53. //        //更新记录
  54. //        userInfo.setNationality("中国台湾");
  55. //        userInfoDataService.updateData(userInfo);
  56. //
  57. //        userInfoDataService.selectDataById(8);
  58. //        userInfoDataService.selectAll();
  59. //
  60. //        //删除记录
  61. //        userInfoDataService.deleteData(8);
  62. //
  63. //        userInfoDataService.selectAll();
  64.  
  65.     }
  66. }

 【日志log打印】

【src】目录下添加文件，如果不放在/src目录下会报错！

  1. ### 设置Logger输出级别和输出目的地 ###
  2. log4j.rootLogger=debug,stdout,logfile
  3.  
  4. ### 把日志信息输出到控制台 ###
  5. log4j.appender.stdout=org.apache.log4j.ConsoleAppender
  6. #log4j.appender.stdout.Target=System.err
  7. log4j.appender.stdout.layout=org.apache.log4j.SimpleLayout
  8.  
  9. ### 把日志信息输出到文件：jbit.log ###
  10. log4j.appender.logfile=org.apache.log4j.FileAppender
  11. log4j.appender.logfile.File=jbit.log
  12. log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
  13. log4j.appender.logfile.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %F %p %m%n
  14.  
  15. ###显示SQL语句部分
  16. log4j.logger.com.ibatis=DEBUG
  17. log4j.logger.com.ibatis.common.jdbc.SimpleDataSource=DEBUG
  18. log4j.logger.com.ibatis.common.jdbc.ScriptRunner=DEBUG
  19. log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate=DEBUG
  20. log4j.logger.java.sql.Connection=DEBUG
  21. log4j.logger.java.sql.Statement=DEBUG
  22. log4j.logger.java.sql.PreparedStatement=DEBUG

  1. <?xml version="1.0" encoding="UTF-8"?>
  2.  
  3. <Configuration status="OFF">
  4.     <Appenders>
  5.         <Console name="Console" target="SYSTEM_OUT">
  6.             <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n" />
  7.         </Console>
  8.     </Appenders>
  9.     <Loggers>
  10.         <Logger name="hive.server2.query.ApiQueryTest" level="trace">
  11.             <AppenderRef ref="Console" />
  12.         </Logger>
  13.         <Logger name="hive.server2.query" level="debug">
  14.             <AppenderRef ref="Console" />
  15.         </Logger>
  16.         <Root level="error">
  17.             <AppenderRef ref="Console" />
  18.         </Root>
  19.     </Loggers>
  20. </Configuration>

【output】

 

 

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小蓝xlanll/article/detail/559138
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号