基于 MyBatis3 的基本操作介紹
每 一 個 MyBatis 的 應 用 程 序 都 以 一 個 SqlSessionFactory 對 象 的 實 例 為 核 心 。一般而言，在一個應用中，一個數據庫只會對應一個SqlSessionFactory，所以一般我們都把SqlSessionFactory定義成單例模式，或通過Spring等進行注入。
從XML中構建SqlSessionFactory
private static SqlSessionFactory sqlSessionFactory = null;static { try { InputStream is = Resources.getResourceAsStream("config/mybatis_config.xml"); sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static SqlSessionFactory getSqlSessionFactory() { return sqlSessionFactory; }</pre>下面講講配置文件的基本結構：
mybatis的配置文件一般包括如下幾個部分：
properties：properties用于定義或導入屬性，然后在后面的環境中使用
settings:settings用于設置一些mybatis在運行時的行為方式，具體的設置信息可以查看mybatis的文檔
typeAliases:typeAliases是為系統中的Java類型指定一個較短的別名
environments:MyBatis 可以配置多種環境。這會幫助你將 SQL 映射應用于多種數據庫之中。
<environments default="development"> <environment id="development"> <transactionManager type="JDBC" /> <dataSource type="POOLED"> <property name="driver" value="${jdbc.driver}" /><property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </dataSource> </environment> </environments></pre>transactionManager
在 MyBatis 中有兩種事務管理器類型(也就是 type=”[JDBC|MANAGED]”):
- JDBC – 這個配置直接簡單使用了 JDBC 的提交和回滾設置。 它依賴于從數據源得 到的連接來管理事務范圍。
- MANAGED – 這個配置幾乎沒做什么。它從來不提交或回滾一個連接。而它會讓 容器來管理事務的整個生命周期(比如 Spring 或 JEE 應用服務器的上下文) 默認 情況下它會關閉連接。 然而一些容器并不希望這樣, 因此如果你需要從連接中停止 它,將 closeConnection 屬性設置為 false。
dataSource
dataSource 元素使用基本的 JDBC 數據源接口來配置 JDBC 連接對象的資源。
- 許多 MyBatis 的應用程序將會按示例中的例子來配置數據源。 然而它并不是必須的。 要知道為了方便使用延遲加載,數據源才是必須的。
有三種內建的數據源類型(也就是 type=”???”):
UNPOOLED – 這個數據源的實現是每次被請求時簡單打開和關閉連接。它有一點慢, 這是對簡單應用程序的一個很好的選擇, 因為它不需要及時的可用連接。 不同的數據庫對這 個的表現也是不一樣的, 所以對某些數據庫來說配置數據源并不重要, 這個配置也是閑置的。 UNPOOLED 類型的數據源僅僅用來配置以下 5 種屬性:
- driver – 這是 JDBC 驅動的 Java 類的完全限定名(如果你的驅動包含,它也不是 數據源類)。
- url – 這是數據庫的 JDBC URL 地址。
- username – 登錄數據庫的用戶名。
- password – 登錄數據庫的密碼。
- defaultTransactionIsolationLevel – 默認的連接事務隔離級別。
作為可選項,你可以傳遞數據庫驅動的屬性。要這樣做,屬性的前綴是以“driver.”開 頭的,例如:
- driver.encoding=UTF8
這 樣 就 會 傳 遞 以 值 “ UTF8 ” 來 傳 遞 屬 性 “ encoding ”, 它 是 通 過 DriverManager.getConnection(url,driverProperties)方法傳遞給數據庫驅動。
POOLED – 這是 JDBC 連接對象的數據源連接池的實現,用來避免創建新的連接實例 時必要的初始連接和認證時間。這是一種當前 Web 應用程序用來快速響應請求很流行的方 法。
除了上述(UNPOOLED)的屬性之外,還有很多屬性可以用來配置 POOLED 數據源:
- poolMaximumActiveConnections – 在任意時間存在的活動(也就是正在使用)連 接的數量。默認值:10
- poolMaximumIdleConnections – 任意時間存在的空閑連接數。
- poolMaximumCheckoutTime – 在被強制返回之前,池中連接被檢查的時間。默認 值:20000 毫秒(也就是 20 秒)
- poolTimeToWait – 這是給連接池一個打印日志狀態機會的低層次設置,還有重新 嘗試獲得連接, 這些情況下往往需要很長時間 為了避免連接池沒有配置時靜默失 敗)。默認值:20000 毫秒(也就是 20 秒)
- poolPingQuery – 發送到數據的偵測查詢,用來驗證連接是否正常工作,并且準備 接受請求。默認是“NO PING QUERY SET” ,這會引起許多數據庫驅動連接由一 個錯誤信息而導致失敗。
- poolPingEnabled – 這是開啟或禁用偵測查詢。如果開啟,你必須用一個合法的 SQL 語句(最好是很快速的)設置 poolPingQuery 屬性。默認值:false。
- poolPingConnectionsNotUsedFor – 這是用來配置 poolPingQuery 多次時間被用一次。 這可以被設置匹配標準的數據庫連接超時時間, 來避免不必要的偵測。 默認值: 0(也就是所有連接每一時刻都被偵測-但僅僅當 poolPingEnabled 為 true 時適用)。
JNDI – 這個數據源的實現是為了使用如 Spring 或應用服務器這類的容器, 容器可以集 中或在外部配置數據源,然后放置一個 JNDI 上下文的引用。這個數據源配置只需要兩個屬 性:
- initial_context – 這 個 屬 性 用 來 從 初 始 上 下 文 中 尋 找 環 境 ( 也 就 是 initialContext.lookup(initial——context) 。這是個可選屬性,如果被忽略,那么 data_source 屬性將會直接以 initialContext 為背景再次尋找。
- data_source – 這是引用數據源實例位置的上下文的路徑。它會以由 initial_context 查詢返回的環境為背景來查找,如果 initial_context 沒有返回結果時,直接以初始 上下文為環境來查找。
<mappers>
<mapper resource="com/tiantian/mybatis/model/BlogMapper.xml"/>
</mappers>
<?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 resource="config/jdbc.properties"></properties> <typeAliases> <typeAlias alias="Blog" type="com.tiantian.mybatis.model.Blog"/></typeAliases> <environments default="development"> <environment id="development"> <transactionManager type="JDBC" /> <dataSource type="POOLED"> <property name="driver" value="${jdbc.driver}" /> <property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </dataSource> </environment> </environments> <mappers> <mapper resource="com/tiantian/mybatis/model/BlogMapper.xml"/> </mappers></configuration></pre> </div>
在有了SqlSessionFactory之后就是獲取特定的SqlSession了，在使用mybatis的過程中每一個操作都是離不開SqlSession的，所以獲取SqlSession是相當重要的。此外，SqlSession是不能被共享、線程不安全的，所以在每次需要SqlSession的時候都應該打開一個，然后在用完了之后再把它關上。SqlSession session = sqlSessionFactory.openSession();mybatis的基本操作就是增、刪、改、查，即insert、delete、update和select。在進行這些基本的操作的時候可以直接利用SqlSession訪問Mapper配置文件里面的映射來進行，也可以利用與Mapper配置文件相對應的Mapper接口來進行操作，條件是Mapper接口中定義的方法的參數和返回值要與Mapper配置文件中定義的參數和返回值相同。此外，在使用Mapper接口的時候，對應的SQL語句是可以寫在Mapper配置文件中的，也可以直接利用對應的注解在Mapper接口中對應的方法上進行標明，這將在下面的示例代碼中看到。</div>
下面是一系列的示例代碼：先貼一個用于獲取SqlSessionFactory的工具類：import java.io.IOException; import java.io.InputStream;import org.apache.ibatis.io.Resources; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder;
public class Util {
private static SqlSessionFactory sqlSessionFactory = null; static { try { InputStream is = Resources.getResourceAsStream("config/mybatis_config.xml"); sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static SqlSessionFactory getSqlSessionFactory() { return sqlSessionFactory; }}</pre> </div>
mybatis的配置文件：<?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 resource="config/jdbc.properties"></properties> <typeAliases><typeAlias alias="Blog" type="com.tiantian.mybatis.model.Blog"/> </typeAliases> <environments default="development"> <environment id="development"> <transactionManager type="JDBC" /> <dataSource type="POOLED"> <property name="driver" value="${jdbc.driver}" /> <property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </dataSource> </environment> </environments> <mappers> <mapper resource="com/tiantian/mybatis/model/BlogMapper.xml"/> </mappers></configuration></pre> </div>
BlogMapper.xml<?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.tiantian.mybatis.model.BlogMapper"> <!-- 新增記錄 --> <insert id="insertBlog" parameterType="Blog"> insert into t_blog(title,content,owner) values(#{title},#{content},#{owner}) </insert>
<!-- 查詢單條記錄 --> <select id="selectBlog" parameterType="int" resultType="Blog"> select * from t_blog where id = #{id} </select> <!-- 修改記錄 --> <update id="updateBlog" parameterType="Blog"> update t_blog set title = #{title},content = #{content},owner = #{owner} where id = #{id} </update>
<!-- 查詢所有記錄，查詢多條記錄即返回結果是一個集合的時候，resultType不是集合類型，而是集合所包含的類型 --> <select id="selectAll" resultType="Blog"> select from t_blog </select> <!-- 模糊查詢 --> <select id="fuzzyQuery" resultType="Blog" parameterType="java.lang.String"> select from t_blog where title like "%"#{title}"%" </select>
<!-- 刪除記錄 --> <delete id="deleteBlog" parameterType="int"> delete from t_blog where id = #{id} </delete> </mapper></pre> </div>
SQL映射語句中一些應該注意的問題：
- resultType的值應該是返回類型的完全名或別名，當返回的結果是一個集合的時候，resultType應為集合中所包含的類型，而不是集合類型，如上面的Blog
- resultType和resultMap都是表示指定返回結果的，但兩者不能同時使用
- 對于Insert映射語句有一個useGeneratedKeys屬性，該屬性的默認值為false，當該屬性的值為true時，在進行插入操作時，mybatis會取到當前正在插入的記錄在數據庫中的自動遞增的主鍵值，并把它設置給指定的實體的屬性，這就需要設置一個keyProperty屬性，用于指定實體中表示主鍵的屬性
Blog.javapackage com.tiantian.mybatis.model;public class Blog {
private int id; private String title; private String content; private String owner; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getTitle() { return title; } public void setTitle(String title) { this.title = title; } public String getContent() { return content; } public void setContent(String content) { this.content = content; } public String getOwner() { return owner; } public void setOwner(String owner) { this.owner = owner; } @Override public String toString() { return "id: " + id + ", title: " + title + ", content: " + content + ", owner: " + owner; }}</pre> </div>
BlogMapper.javapackage com.tiantian.mybatis.model;import java.util.List;
import org.apache.ibatis.annotations.Delete; import org.apache.ibatis.annotations.Insert; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Update;
/**
- 以下的操作1都是把SQL寫在配置文件里面的，而操作2都是直接用注解標明要執行的SQL語句
- 因為該Mapper的全名跟BlogMapper.xml文件里面的namespace是一樣的，所以不能在這里面
- 用注解定義一個與BlogMapper.xml文件里面同名的映射
@author andy / public interface BlogMapper {
public Blog selectBlog(int id);
@Select("select * from t_blog where id = #{id}") public Blog selectBlog2(int id);
public void insertBlog(Blog blog);
@Insert("insert into t_blog(title,content,owner) values(#{title},#{content},#{owner})") public void insertBlog2(Blog blog);
public void updateBlog(Blog blog);
@Update("update t_blog set title=#{title},content=#{content},owner=#{owner} where id=#{id}") public void updateBlog2(Blog blog);
public void deleteBlog(int id);
@Delete("delete from t_blog where id = #{id}") public void deleteBlog2(int id);
public List<Blog> selectAll();
@Select("select * from t_blog") public List<Blog> selectAll2();
public List<Blog> fuzzyQuery(String title);
@Select("select * from t_blog where title like \"%\"#{title}\"%\"") public List<Blog> fuzzyQuery2(String title);
}</pre> </div>
Test1.javapackage com.tiantian.mybatis.test;import java.util.List;
import org.apache.ibatis.session.SqlSession; import org.junit.Test;
import com.tiantian.mybatis.model.Blog; import com.tiantian.mybatis.util.Util;
/**
- 該系列操作是通過把SQL寫在配置文件里面，
- 然后利用SqlSession進行操作的
@author andy / public class Test1 {
/**
新增記錄 */ @Test public void testInsertBlog() { SqlSession session = Util.getSqlSessionFactory().openSession(); Blog blog = new Blog(); blog.setTitle("中國人"); blog.setContent("五千年的風和雨啊藏了多少夢"); blog.setOwner("天天"); session.insert("com.tiantian.mybatis.model.BlogMapper.insertBlog", blog); session.commit(); session.close(); }
/**
查詢單條記錄 */ @Test public void testSelectOne() { SqlSession session = Util.getSqlSessionFactory().openSession(); Blog blog = (Blog)session.selectOne("com.tiantian.mybatis.model.BlogMapper.selectBlog", 8); System.out.println(blog); session.close(); }
/**
修改記錄 */ @Test public void testUpdateBlog() { SqlSession session = Util.getSqlSessionFactory().openSession(); Blog blog = new Blog(); blog.setId(7);//需要修改的Blog的id blog.setTitle("中國人2");//修改Title blog.setContent("黃色的臉，黑色的眼，不變是笑容");//修改Content blog.setOwner("天天2");//修改Owner session.update("com.tiantian.mybatis.model.BlogMapper.updateBlog", blog); session.commit(); session.close(); }
/**
查詢所有的記錄 */ @Test public void testSelectAll() { SqlSession session = Util.getSqlSessionFactory().openSession(); List<Blog> blogs = session.selectList("com.tiantian.mybatis.model.BlogMapper.selectAll"); for (Blog blog:blogs)
System.out.println(blog);session.close(); }
/**
模糊查詢 */ @Test public void testFuzzyQuery() { SqlSession session = Util.getSqlSessionFactory().openSession(); String title = "中國"; List<Blog> blogs = session.selectList("com.tiantian.mybatis.model.BlogMapper.fuzzyQuery", title); for (Blog blog:blogs)
System.out.println(blog);session.close(); }
/**
- 刪除記錄 */ @Test public void testDeleteBlog() { SqlSession session = Util.getSqlSessionFactory().openSession(); session.delete("com.tiantian.mybatis.model.BlogMapper.deleteBlog", 8); session.commit(); session.close(); }
}</pre> </div>
Test2.javapackage com.tiantian.mybatis.test;import java.util.List;
import org.apache.ibatis.session.SqlSession; import org.junit.Test;
import com.tiantian.mybatis.model.Blog; import com.tiantian.mybatis.model.BlogMapper; import com.tiantian.mybatis.util.Util;
/**
- 該系列操作是將SQL語句寫在配置文件里面，
- 然后通過對應Mapper接口來進行操作的
@author andy / public class Test2 {
/**
新增記錄 */ @Test public void testInsertBlog() { SqlSession session = Util.getSqlSessionFactory().openSession(); Blog blog = new Blog(); blog.setTitle("中國人"); blog.setContent("五千年的風和雨啊藏了多少夢"); blog.setOwner("天天"); BlogMapper blogMapper = session.getMapper(BlogMapper.class); blogMapper.insertBlog(blog); session.commit(); session.close(); }
/**
查詢單條記錄 */ @Test public void testSelectOne() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); Blog blog = blogMapper.selectBlog(7); System.out.println(blog); session.close(); }
/**
修改記錄 */ @Test public void testUpdateBlog() { SqlSession session = Util.getSqlSessionFactory().openSession(); Blog blog = new Blog(); blog.setId(9);// 需要修改的Blog的id blog.setTitle("中國人2");// 修改Title blog.setContent("黃色的臉，黑色的眼，不變是笑容");// 修改Content blog.setOwner("天天2");// 修改Owner BlogMapper blogMapper = session.getMapper(BlogMapper.class); blogMapper.updateBlog(blog); session.commit(); session.close(); }
/**
查詢所有記錄 */ @Test public void testSelectAll() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); List<Blog> blogs = blogMapper.selectAll(); for (Blog blog : blogs)
System.out.println(blog);session.close(); }
/**
模糊查詢 */ @Test public void testFuzzyQuery() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); String title = "中國"; List<Blog> blogs = blogMapper.fuzzyQuery(title); for (Blog blog : blogs)
System.out.println(blog);session.close(); }
/**
- 刪除記錄 */ @Test public void testDeleteBlog() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); blogMapper.deleteBlog(10); session.commit(); session.close(); }
}</pre> </div>
Test3.javapackage com.tiantian.mybatis.test;import java.util.List;
import org.apache.ibatis.session.SqlSession; import org.junit.Test;
import com.tiantian.mybatis.model.Blog; import com.tiantian.mybatis.model.BlogMapper; import com.tiantian.mybatis.util.Util;
/**
- 該系列操作是利用Mapper接口來進行的
- ，然而其相應的SQL語句是通過對應的
- 注解Annotation在Mapper中對應的方法上定義的
@author andy / public class Test3 {
/**
新增記錄 */ @Test public void testInsert() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); Blog blog = new Blog(); blog.setTitle("title2"); blog.setContent("content2"); blog.setOwner("owner2"); blogMapper.insertBlog2(blog); session.commit(); session.close(); }
/**
查找單條記錄 */ @Test public void testSelectOne() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); Blog blog = blogMapper.selectBlog2(1); System.out.println(blog); session.close(); }
/**
查找多條記錄，返回結果為一集合 */ @Test public void testSelectAll() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); List<Blog> blogs = blogMapper.selectAll2(); for (Blog blog:blogs)
System.out.println(blog);session.close(); }
/**
修改某條記錄 */ @Test public void testUpdate() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); Blog blog = new Blog(); blog.setId(3); blog.setTitle("title3"); blog.setContent("content3"); blog.setOwner("owner3"); blogMapper.updateBlog2(blog); session.commit(); session.close(); }
/**
刪除記錄 */ @Test public void testDelete() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); blogMapper.deleteBlog2(5); session.commit(); session.close(); }
@Test public void testFuzzyQuery() { SqlSession session = Util.getSqlSessionFactory().openSession(); BlogMapper blogMapper = session.getMapper(BlogMapper.class); List<Blog> blogs = blogMapper.fuzzyQuery2("中國"); for (Blog blog:blogs)
System.out.println(blog);session.close(); }
}</pre> </div>
對應的建表語句：CREATE TABLE `t_blog` ( `id` int(11) NOT NULL AUTO_INCREMENT, `title` varchar(255) DEFAULT NULL, `content` varchar(255) DEFAULT NULL, `owner` varchar(50) DEFAULT NULL, PRIMARY KEY (`id`) )轉自： http://haohaoxuexi.iteye.com/blog/1333271本文由用戶 fmms 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！sesese色