Spring กับ DAO
หลังจากที่เราจัดการเชื่อมต่อกับฐานข้อมูลแล้วดังนั้นตอนนี้เหมือนเรามี ท่อสำหรับเชื่อมต่อกับตาน้ำบาดาล
แล้วต่อไปเราจะเริ่ม ใส่เครื่องสูบน้ำเข้าไปบนต่อนั้นโดย สิ่งที่จะทำการสูบข้อมูลออกมาจาก
ฐานข้อมูลนั้นสำหรับสปริงเราเรียกว่าชั้นของดาว DAO(Data Access Object) ซึ่งชื่อนี้ก็ไม่ใช่อื่นไกลมัน
คือหนึ่งใน Design Pattern อันโด่งดังนั่นเอง โดยสรุปหน้าที่หลักของ DAO นั้นคือเป็นคนที่มีหน้าที่ในการ
ควบคุม Operation ฑื้นฐานต่างๆที่เราพึงจะกระทำต่อหนึ่งตารางในระบบฐานข้อมูลนั่นคือ
CRUD(Create Read/Retrive Update Delete)
นั่นเองและย้ำเราจะมีหนึ่ง DAO ต่อหนึ่งตารางเท่านั้น
และต่อไปอย่างที่ได้เกริ่นไว้แล้วว่าผมจะใช้ iBatis เข้ามาช่วยในการ map ข้อมูลในตารางออกมาเป็น
Java Object ดังนั้นผมจึงขอ assume ว่าทุกคนมีพื้นเรื่อง iBatis แล้วครับ (เหอๆๆๆๆ เดี่ยวจะกลับมาเล่าอีกที)
แต่ก่อนอื่นเอาคร่าวๆก่อนแล้วกันครับ ในตัวอย่างนี้เรามีตารางชื่อ USERS ที่มี Schema ดังนี้

CREATE TABLE /*!32312 IF NOT EXISTS*/ `users` (
  `USR_ID` tinyint(3) unsigned NOT NULL DEFAULT '0',
  `USR_NAME` varchar(50) NOT NULL DEFAULT '',
  `USR_PWD` varchar(50) DEFAULT NULL,
  `USR_LEVEL` int(10) unsigned DEFAULT NULL,
  `USR_FIRST_LOGIN` date DEFAULT NULL,
  `REG_DATE` date NOT NULL,
  `LOG_DATE` date DEFAULT NULL,
  PRIMARY KEY (`USR_NAME`)
) ENGINE=InnoDB /*!40100 DEFAULT CHARSET=utf8*/;

และเราต้องการที่จะเชื่อมตารางนี้เข้ากับ Doamin class ชื่อ Users ของเราที่มีรายละเอียดตามนี้ครับ

package com.spring66.tutorial.model;
import java.util.Date;
public class Users {
    private String usrId;
    private String usrName;
    private String usrPwd;
    private Integer usrLevel;
    private Date usrFirstLogin;
    private Date regDate;
    private Date logDate;
    ...
    //all get and set methods
}

ซึ่งจริงๆแล้วเราสามารถใช้เครื่องมือที่ชื่อ abator เข้ามาช่วยเราในการสร้างตั้งแต่ Domain Class ไปจนถึง DAO ได้เลย
แต่เพื่อความรู้พื้นฐานผมจะอธิบายเป็นส่วนๆแล้วกันนะครับว่าเป็นอย่างไร การเชื่อมนั้นจริงๆแล้วเราต้องสร้าง configuration file
ขึ้นมาเพือบอกรายละเอียดของตารางและdomain ให้กับ iBatis โดยจะเริ่มจากส่วนแรก

  <resultMap id="UsersResult" class="com.spring66.tutorial.model.Users" >
    <result column="USR_ID" property="usrId" jdbcType="CHAR" />
    <result column="USR_NAME" property="usrName" jdbcType="VARCHAR" />
    <result column="USR_PWD" property="usrPwd" jdbcType="VARCHAR" />
    <result column="USR_LEVEL" property="usrLevel" jdbcType="INTEGER" />
    <result column="USR_FIRST_LOGIN" property="usrFirstLogin" jdbcType="TIMESTAMP" />
    <result column="REG_DATE" property="regDate" jdbcType="TIMESTAMP" />
    <result column="LOG_DATE" property="logDate" jdbcType="TIMESTAMP" />
  </resultMap>

ส่วนนี้จะทำการเชื่อม attribute ต่างๆของเราเข้ากับ field ในฐานข้อมูลต่อไปเรามาดูกันว่าถ้าเราต้องการ SELECT ขึ้นมาจะ
ต้องเขียน เพิ่มอย่างไร

  <select id="Users_selectByPrimaryKey" resultMap="UsersResult" parameterClass="com.spring66.tutorial.model.Users" >
    select USR_ID, USR_NAME, USR_PWD, USR_LEVEL, USR_FIRST_LOGIN, REG_DATE, LOG_DATE
    from users
    where USR_ID = #usrId:CHAR#
  </select>

จะเห็นได้ว่าสิ่งที่เราต้องการทำก็มีแค่เพียงกำหนด SQL Statement ที่ต้องการเข้าไปให้ iBatis และบอกว่าผลที่ได้ให้ map ใส่ object ชื่ออะไรเท่านั้นเองในกรณี INSERT ก็
จะออกมาในลักษณะนี้ครับ

  <insert id="Users_insert" parameterClass="com.spring66.tutorial.model.Users" >
    insert into users (USR_ID, USR_NAME, USR_PWD, USR_LEVEL, USR_FIRST_LOGIN, REG_DATE, LOG_DATE)
    values (#usrId:CHAR#, #usrName:VARCHAR#, #usrPwd:VARCHAR#, #usrLevel:INTEGER#,
      #usrFirstLogin:INTEGER#, #regDate:TIMESTAMP#, #logDate:TIMESTAMP#)
  </insert>

อันนี้จะคิดกลับกันหน่อยคือเราต้องบอกว่าเราจะส่งอะไรให้ iBatis ครับแล้วเราจะ map มันอย่างไร เอาคร่าวๆแค่นี้ก่อนนะครับ ที่เหลือไปอ่านต่อเองครับ
และเพื่อให้เป็นไปตาม concept ของเรา TDD เราจะเริ่มด้วยการเขียน test ก่อนครับ อยากให้
usersDao ทำอะไรได้บ้างก็ร่ายมาเลยครับโดยของผมเป็นแบบนี้ครับ

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package com.spring66.tutorial.dao;
//import some libs
/**
 *
 * @author TwinP
 */
public class IbatisUserDaoTest extends AbstractDependencyInjectionSpringContextTests {
    protected final Log log = LogFactory.getLog(getClass());
    private UsersDao usersDao;
    @Override
    protected String[] getConfigLocations() {
        setAutowireMode(AUTOWIRE_BY_NAME);
        return new String[]{
                    "classpath:/applicationContext.xml",
                    "classpath*:/applicationContext.xml" // for modular projects
                };
    }
    public void testLoadBean() {
        log.debug("Looking 4 UsersDao First");
        assertNotNull(usersDao);
    }

    public void testCreateUsers() {
        Users u = new Users();
        u.setLogDate(new Date());
        u.setRegDate(new Date());
        u.setUsrFirstLogin(new Date());
        u.setUsrId("1");
        u.setUsrLevel(new Integer(1));
        u.setUsrName("username");
        u.setUsrPwd("password");
        usersDao.insert(u);
    }

    public void testGetUsers() {
        UsersExpression usrEx = new UsersExpression();
        usrEx.createCriteria().andUsrNameEqualTo("username");
        List<Users> usr = usersDao.selectByExpression(usrEx);
        assertEquals(1, usr.size());
    }

    public void testUpdateUsers() {
        UsersExpression usrEx = new UsersExpression();
        usrEx.createCriteria().andUsrNameEqualTo("username");
        //Also can do something like this usrEx.createCriteria().andUsrNameLike("%us%");
        List<Users> usr = usersDao.selectByExpression(usrEx);
        Users user = usr.get(0);
        user.setRegDate(null);
        try {
            usersDao.updateByPrimaryKey(user);
            fail("This operation can not be done because RegDate can not be NULL, there is something WRONG!!!!!!");
        } catch (Exception error) {
            log.debug("OK that's true PK can not be NULL " + error.toString());
        }
    }

    public void testDeleteUsers() {
        usersDao.deleteByPrimaryKey("username");
        UsersExpression usrEx = new UsersExpression();
        usrEx.createCriteria().andUsrNameLike("%user%");
        //Also can do something like this usrEx.createCriteria().andUsrNameLike("%us%");
        List<Users> usr = usersDao.selectByExpression(usrEx);
        assertNull(usr);
    }

 // get set
}

และแน่นอนกล้าเขียนก็กล้า error เพราะมันจะแดงเถือกเลยครับอันดับแรกที่เราจะทำคือ สร้าง UsersDao ครับแต่เป็น interface นะ

package com.spring66.tutorial.dao;
import com.spring66.tutorial.model.Users;
import com.spring66.tutorial.model.UsersExpression;
import java.util.List;
public interface UsersDao {
    void insert(Users record);
    int updateByPrimaryKey(Users record);
    int updateByPrimaryKeySelective(Users record);
    List selectByExpression(UsersExpression expression);
    Users selectByPrimaryKey(String usrId);
    int deleteByExpression(UsersExpression expression);
    int deleteByPrimaryKey(String usrId);
    int countByExpression(UsersExpression exampexpressionle);
    int updateByExpressionSelective(Users record, UsersExpression expression);
    int updateByExpression(Users record, UsersExpression expression);
}

เท่านี้อาการแดงเถือกจะลดลงไปได้บ้าง และเพื่อไม่ให้ entry มันยาวเกินจบตอนนี้ก่อนนะครับ เพราะ

• Previous Entry: Solving Integration Problems using Patterns ภาค2
• Next Entry: Spring กับ iBatisDao ภาค2