Tablestore：通過MyBatis使用SQL查詢

步驟三：映射 SQL 欄位

1. 建立資料表欄位對應的 Java Bean。在本樣本中 trip_id 為資料表中的唯一主鍵。

   重要

   Java Bean 的成員變數名稱必須和資料表的欄位名相同。

   package mybatis;
   
   public class Trip {
   
       private long trip_id;
       private long duration;
       private String start_date;
       private String end_date;
       private long start_station_number;
       private long end_station_number;
       private String start_station;
       private String end_station;
       private String bike_number;
       private String member_type;
   
       // 以 trip_id 為例，其他欄位類似。
       public void setTrip_Id(Long trip_id){
           this.trip_id = trip_id;
       }
       public Long getTrip_Id() {
           return trip_id;
       }
   }

2. 建立映射設定檔，並在映射設定檔中定義查詢條件。此處以在 mybatis 目錄下建立 TripMapper.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="mybatis.TripMapper">
       <select id="selectTrip" resultType="mybatis.Trip">
           select * from trips where trip_id = #{id}
       </select>
   </mapper>

步驟四：構建 SqlSessionFactory

SqlSessionFactory 用於建立 MyBatis 會話，通過會話串連Table Store。

1. 建立 MyBatis 設定檔 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">
   <configuration>
       <environments default="development">
           <environment id="development">
               <transactionManager type="JDBC"/>
               <!-- Table Store JDBC 驅動需主動關閉才能退出進程。常駐程式用 POOLED，查完即退用 UNPOOLED。 -->
               <dataSource type="UNPOOLED">
                   <property name="driver" value="com.alicloud.openservices.tablestore.jdbc.OTSDriver"/>
                   <property name="url" value="jdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance"/>
                   <property name="username" value="***********************"/>
                   <property name="password" value="********************************"/>
               </dataSource>
           </environment>
       </environments>
       <mappers>
           <!-- 設定為映射設定檔的路徑。-->
           <mapper resource="mybatis/TripMapper.xml"/>
       </mappers>
   </configuration>

   配置項說明如下。

   配置項	類型	是否必選	描述
   driver	class	是	Table Store JDBC 驅動的類名，固定為 com.alicloud.openservices.tablestore.jdbc.OTSDriver。
   url	string	是	執行個體訪問地址。格式為jdbc:ots:endpoint/instanceName，其中 endpoint 為執行個體的服務地址，instanceName 為執行個體名稱，根據實際情況修改。
   username	string	是	阿里雲帳號或者 RAM 使用者的 AccessKey ID。
   password	string	是	阿里雲帳號或者 RAM 使用者的 AccessKey Secret。

2. 通過載入 MyBatis 設定檔構建 SqlSessionFactory。

   String resource = "mybatis/mybatis-config.xml";
   InputStream inputStream = Resources.getResourceAsStream(resource);
   SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

步驟五：建立 SqlSession 查詢資料

Table Store不支援事務，openSession 的 autoCommit 參數必須設定為 true。

SqlSession session = sqlSessionFactory.openSession(true);
Trip trip = (Trip) session.selectOne("mybatis.TripMapper.selectTrip", 99L);
System.out.println("trip id: " + trip.getTrip_id());
System.out.println("start date: " + trip.getStart_date());
System.out.println("end date: " + trip.getEnd_date());
System.out.println("duration: " + trip.getDuration());
session.close();