使用mybatis框架完成資料庫中的CRUD（使用工具類）
阿新 • • 發佈：2019-02-14
mybatis框架的核心配置檔案：建立一個名為resource的資原始檔夾 ，用來存放配置檔案
mybatis-config.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">
<!--
完成一個mybatis-config.xml的檔案
-> 作用：配置連線資料庫的所有需要的環境
必須連線到所有要使用的對映檔案（ProductMapper.xml）
-->
<!--configuration 根目錄 -->
<configuration>
<!-- 引入（關聯）db.properties檔案 -->
<properties resource="db.properties"></properties>
<!-- 環境們：很多環境 default：表示預設使用哪一個環境-->
<environments default="development">
<!-- 單個環境：一個環境 id：表示這個環境的名稱-->
<environment id="development">
<!-- transactionManager：事務管理器 （使用的JDBC事務管理器）-->
<transactionManager type="JDBC"></transactionManager>
<!-- MyBatis自帶POOLED連線池（資料來源） -->
<dataSource type="POOLED">
<property name="driver" value="${db_driverClassname}" />
<property name="url" value="${db_url}" />
<property name="username" value="${db_username}" />
<property name="password" value="${db_password}" />
</dataSource>
</environment>
</environments>
<!-- resource:表示 核心配置檔案（mybatis-config.xml）必須與所有的物件對映檔案（ProductMapper.xml）關聯！！！！ -->
<mappers>
<mapper resource="cn/itsource/domain/ProductMapper.xml" />
</mappers>
</configuration> db.properties檔案：
db_driverClassname=com.mysql.jdbc.Driver
db_url=jdbc:mysql://localhost:3306/test666
db_username=root
db_password=admin檢視mybatis執行日誌所需配置檔案：檔名為:log4j.properties
log4j.rootLogger=ERROR, stdout
#log4j.rootLogger=NONE
log4j.logger.cn.itsource=TRACE
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
domain包域物件：
package cn.itsource.domain;
/**
* 域物件
* */
public class Product {
/**
* 商品id
* */
private Long id;
/**
* 商品名稱
* */
private String productName;
/**
* 商品品牌
* */
private String brand;
/**
* 商品供應商
* */
private String supplier;
/**
* 商品零售價
* */
private Double salePrice;
/**
* 商品成本價
* */
private Double costPrice;
/**
* 商品折扣
* */
private Double cutoff;
/**
* 商品分類編號
* */
private Long dir_id;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getProductName() {
return productName;
}
public void setProductName(String productName) {
this.productName = productName;
}
public String getBrand() {
return brand;
}
public void setBrand(String brand) {
this.brand = brand;
}
public String getSupplier() {
return supplier;
}
public void setSupplier(String supplier) {
this.supplier = supplier;
}
public Double getSalePrice() {
return salePrice;
}
public void setSalePrice(Double salePrice) {
this.salePrice = salePrice;
}
public Double getCostPrice() {
return costPrice;
}
public void setCostPrice(Double costPrice) {
this.costPrice = costPrice;
}
public Double getCutoff() {
return cutoff;
}
public void setCutoff(Double cutoff) {
this.cutoff = cutoff;
}
public Long getDir_id() {
return dir_id;
}
public void setDir_id(Long dir_id) {
this.dir_id = dir_id;
}
@Override
public String toString() {
return "Product [id=" + id + ", productName=" + productName + ", brand=" + brand + ", supplier=" + supplier
+ ", salePrice=" + salePrice + ", costPrice=" + costPrice + ", cutoff=" + cutoff + ", dir_id=" + dir_id
+ "]";
}
} 配置物件關係對映檔案（ProductMapper.xml）：用來寫sql語句
<?xml version="1.0" encoding="UTF-8"?>
<!-- 完成一個物件關係對映檔案 ->
作用：一個物件的所有SQL都應該寫在這個對映檔案中 這個檔案一般和我們的domain寫在同一個包裡面，取名為
-> domain的名稱+Mapper.xml -->
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!-- namespace:名稱空間（每個Mapper必須有名稱空間） -->
<mapper namespace="cn.itsource.domain.ProductMapper">
<!--
select:它裡面寫查詢語句
id：查詢語句的唯一標識（名稱不能重複）
如何在 java程式碼中找到sql語句？ 名稱空間+id
例子：cn.itsource.domain.ProductMapper.select
parameterType：傳入的引數型別。 除了MyBatis支援的型別，其它的型別都通通使用全限定名
resultType:返回的每一條資料的結果型別（結果型別寫許可權定名稱 ） 查詢功能使用
-->
<select id="selectOne" parameterType="Long" resultType="cn.itsource.domain.Product">
select * from product where id = #{id}
</select>
<!-- resultType:表示返回的資料型別 -->
<select id="selectAll" resultType="cn.itsource.domain.Product">
select * from Product
</select>
<!--parameterType :表示傳入引數（Product）。
useGeneratedKeys:是否需要獲取主鍵
keyColumn：主鍵在資料庫中的名稱（不寫的話預設名稱和keyProperty一致）
keyProperty：物件中的屬性(代表主鍵的那個屬性)
-->
<insert id="save" parameterType="cn.itsource.domain.Product"
useGeneratedKeys="true" keyColumn="id" keyProperty="id">
insert into product (productName,dir_id,salePrice,supplier,brand,cutoff,costPrice)
values(#{productName},#{dir_id},#{salePrice},#{supplier},#{brand},#{cutoff},#{costPrice})
</insert>
<!-- parameterType:接收引數沒有寫許可權頂名稱，使用的別名（簡寫） -->
<delete id="delete" parameterType="long">
delete from product where id = #{id}
</delete>
<update id="update" parameterType="cn.itsource.domain.Product">
update product set productName=#{productName},dir_id=#{dir_id},
salePrice=#{salePrice},supplier=#{supplier},brand=#{brand},cutoff=#{cutoff},costPrice=#{costPrice}
where id = #{id}
</update>
</mapper>dao層介面類：
package cn.itsource.dao;
import java.util.List;
import cn.itsource.domain.Product;
/**
* 完成商品的增刪改查
* */
public interface IProductDao {
/**
* 新增商品
* */
void save(Product obj);
/**
* 修改商品資訊
* */
void update(Product obj);
/**
* 刪除商品
* */
void delete(Long id);
/**
* 查詢單條商品資訊
* */
Product queryOne(Long id);
/**
* 查詢所有商品資訊
* */
List<Product> queryAll();
}
測試類：
package cn.itsource.dao;
import java.util.List;
import org.junit.Test;
import cn.itsource.dao.impl.ProductDaoImpl;
import cn.itsource.domain.Product;
/**
* 測試類
* */
public class ProductDaoTest {
IProductDao dao = new ProductDaoImpl();
@Test
public void testSave() {
Product product = dao.queryOne(4L);
product.setProductName("蘋果10");
product.setSalePrice(8000D);
dao.save(product);
}
@Test
public void testUpdate() {
Product product = dao.queryOne(10L);
product.setProductName("小米7777");
dao.update(product);
}
@Test
public void testDelete() {
dao.delete(20L);
}
@Test
public void testQueryOne() {
Product p = dao.queryOne(3L);
System.out.println(p);
}
@Test
public void testQueryAll() {
List<Product> ps = dao.queryAll();
for (Product product : ps) {
System.out.println(product);
}
}
}
工具類：
package cn.itsource.util;
import java.io.IOException;
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 enum MyBatisUtil {
/**
* MyBatis三大核心物件特點：
* SqlSessionFactoryBuilder——建立了SqlSessionFactory後，這個類就不需要存在了
* SqlSessionFactory——被建立，SqlSessionFactory應該在你的應用執行期間都存在
* SqlSession——每個執行緒都應該有它自己的SqlSession例項。SqlSession的例項不能被共享，也是執行緒不安全的
* */
INSTANCE;
//SqlSessionFactory只需要一個
private static SqlSessionFactory factory;
/**
* 把factory放在靜態程式碼塊中的原因？
* 因為factory只需要建立一個，而靜態程式碼塊中的程式碼只會執行一次
* */
static{
try {
//建立一個SqlSession工廠物件，讀取我們的核心配置檔案
factory = new SqlSessionFactoryBuilder().build(Resources
.getResourceAsStream("mybatis-config.xml"));
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 直接返回一個SqlSession物件
* */
public SqlSession openSession(){
//通過SqlSessionFactory建立SqlSession物件
return factory.openSession();
}
}
package cn.itsource.dao.impl;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import cn.itsource.dao.IProductDao;
import cn.itsource.domain.Product;
import cn.itsource.util.MyBatisUtil;
public class ProductDaoImpl implements IProductDao {
@Override
public void save(Product obj) {
//通過MyBatisUtil工具類獲取SqlSession
SqlSession session = MyBatisUtil.INSTANCE.openSession();
try {
//通過session直接執行sql語句
session.insert("cn.itsource.domain.ProductMapper.save", obj);
//提交事務
session.commit();
} catch (Exception e) {
session.rollback();
e.printStackTrace();
}finally {
session.close();
}
}
@Override
public void update(Product obj) {
//通過工具類獲取SqlSession物件
SqlSession session = MyBatisUtil.INSTANCE.openSession();
try {
//通過session直接執行sql語句
session.update("cn.itsource.domain.ProductMapper.update", obj);
//提交事務
session.commit();
} catch (Exception e) {
session.rollback();
e.printStackTrace();
}finally {
session.close();
}
}
@Override
public void delete(Long id) {
//通過工具類獲取SqlSession物件
SqlSession session = MyBatisUtil.INSTANCE.openSession();
try {
//通過session直接執行sql語句
session.delete("cn.itsource.domain.ProductMapper.delete", id);
//提交事務
session.commit();
} catch (Exception e) {
session.rollback();
e.printStackTrace();
}finally {
session.close();
}
}
@Override
public Product queryOne(Long id) {
Product p = null;
//通過工具類獲取SqlSession物件
SqlSession session = MyBatisUtil.INSTANCE.openSession();
try {
//通過session直接執行sql語句 ，返回結果
p = session.selectOne("cn.itsource.domain.ProductMapper.selectOne", id);
} catch (Exception e) {
e.printStackTrace();
}finally {
session.close();
}
return p;
}
@Override
public List<Product> queryAll() {
List<Product> ps = new ArrayList<>();
//通過工具類獲取SqlSession物件
SqlSession session = MyBatisUtil.INSTANCE.openSession();
try {
//通過session直接執行sql語句,返回結果
ps = session.selectList("cn.itsource.domain.ProductMapper.selectAll");
} catch (Exception e) {
e.printStackTrace();
}finally {
session.close();
}
return ps;
}
}