添加客戶
修改
CustomerMapper.xml
添加内容如下。
<insert id="saveCustomer" parameterType="top.it6666.domain.Customer">
INSERT INTO customer (cust_name, cust_profession, cust_phone, email)
VALUES (#{cust_name}, #{cust_profession}, #{cust_phone}, #{email})
</insert>
修改測試類代碼,如下,主要就是把之前的查詢改為了插入。
/**
* @author BNTang
*/
public class TestMain {
public static void main(String[] args) throws Exception {
// 1.建立 SqlSessionFactoryBuilder 對象
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
// 2.加載 SqlMapConfig.xml 配置檔案
InputStream inputStream = Resources.getResourceAsStream("SqlMappingConfig.xml");
// 3.建立 SqlSessionFactory 對象
SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(inputStream);
// 4.建立 SqlSession 對象
SqlSession sqlSession = sqlSessionFactory.openSession();
// 5.執行 SqlSession 對象執行查詢
Customer customer = new Customer();
customer.setCust_name("BNTang");
customer.setCust_phone("18819522017");
customer.setCust_profession("刺客");
customer.setEmail("[email protected]");
sqlSession.insert("saveCustomer", customer);
// 6.送出事務
sqlSession.commit();
// 7.釋放資源
sqlSession.close();
}
}
傳回添加過後自增的主鍵
修改
CustomerMapper.xml
添加内容如下,需要注意
resultType
的類型需要和實體類的一緻。
<insert id="saveCustomer" parameterType="top.it6666.domain.Customer">
<selectKey keyColumn="cust_id" keyProperty="cust_id" order="AFTER" resultType="Integer">
SELECT LAST_INSERT_ID()
</selectKey>
INSERT INTO customer (cust_name, cust_profession, cust_phone, email)
VALUES (#{cust_name}, #{cust_profession}, #{cust_phone}, #{email})
</insert>
修改測試類代碼,如下,主要就是列印一下自增之後的主鍵值内容如下。
/**
* @author BNTang
*/
public class TestMain {
public static void main(String[] args) throws Exception {
// 1.建立 SqlSessionFactoryBuilder 對象
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
// 2.加載 SqlMapConfig.xml 配置檔案
InputStream inputStream = Resources.getResourceAsStream("SqlMappingConfig.xml");
// 3.建立 SqlSessionFactory 對象
SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(inputStream);
// 4.建立 SqlSession 對象
SqlSession sqlSession = sqlSessionFactory.openSession();
// 5.執行 SqlSession 對象執行查詢
Customer customer = new Customer();
customer.setCust_name("BNTang");
customer.setCust_phone("18819522017");
customer.setCust_profession("刺客");
customer.setEmail("[email protected]");
sqlSession.insert("saveCustomer", customer);
System.out.println(customer.getCust_id());
// 6.送出事務
sqlSession.commit();
// 7.釋放資源
sqlSession.close();
}
}
更新客戶
修改
CustomerMapper.xml
添加内容如下。
<update id="updateCustomerById" parameterType="top.it6666.domain.Customer">
UPDATE `customer`
SET cust_name = #{cust_name}
WHERE cust_id = #{cust_id}
</update>
修改測試類代碼,如下。
/**
* @author BNTang
*/
public class TestMain {
public static void main(String[] args) throws Exception {
// 1.建立 SqlSessionFactoryBuilder 對象
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
// 2.加載 SqlMapConfig.xml 配置檔案
InputStream inputStream = Resources.getResourceAsStream("SqlMappingConfig.xml");
// 3.建立 SqlSessionFactory 對象
SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(inputStream);
// 4.建立 SqlSession 對象
SqlSession sqlSession = sqlSessionFactory.openSession();
// 5.執行 SqlSession 對象執行查詢
Customer customer = new Customer();
customer.setCust_name("newBNTang");
customer.setCust_id(14);
sqlSession.update("updateCustomerById", customer);
// 6.送出事務
sqlSession.commit();
// 7.釋放資源
sqlSession.close();
}
}
删除客戶
修改
CustomerMapper.xml
添加内容如下。
<delete id="deleteCustomerById" parameterType="Integer">
DELETE
FROM customer
WHERE cust_id = #{cust_id}
</delete>
修改測試類代碼,如下。
/**
* @author BNTang
*/
public class TestMain {
public static void main(String[] args) throws Exception {
// 1.建立 SqlSessionFactoryBuilder 對象
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
// 2.加載 SqlMapConfig.xml 配置檔案
InputStream inputStream = Resources.getResourceAsStream("SqlMappingConfig.xml");
// 3.建立 SqlSessionFactory 對象
SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(inputStream);
// 4.建立 SqlSession 對象
SqlSession sqlSession = sqlSessionFactory.openSession();
// 5.執行 SqlSession 對象執行查詢
sqlSession.delete("deleteCustomerById", 14);
// 6.送出事務
sqlSession.commit();
// 7.釋放資源
sqlSession.close();
}
}