1 개요

2 쿼리의 유형

2.1 INSERT, UPDATE, DELETE 문을 모두 사용하는 경우

CREATE TABLE ItemObject 
( 
    ItemID    INT         NOT NULL, 
    UserID    VARCHAR(50) NOT NULL, 
    ItemType  INT         NOT NULL, 
    X         INT         NOT NULL, 
    Y         INT         NOT NULL, 
     
    ...생략... 
 
    PRIMARY KEY(ItemID) 
);

플레이어는 새로운 아이템을 사서 인벤토리에다 넣을 수 있다. --> INSERT
플레이어는 아이템을 인벤토리 안에서 움직일 수 있다. --> UPDATE
플레이어는 인벤토리에 있는 아이템을 상점에다 팔아버릴 수 있다. --> DELETE

중복된 UPDATE 하나로 만들기 : 플레이어가 인벤토리 안에 있는 아이템을 이리저리 움직인 경우, 매번 쿼리를 생성할 것이 아니라, 최종적으로 위치가 확정되었을 때, 쿼리를 실행한다.
DELETE할 행에 대한 INSERT 및 UPDATE 무시하기 : 플레이어가 인벤토리 안에 있는 아이템을 팔아버린 경우, 이전의 INSERT 쿼리나 UPDATE 쿼리는 무시한다. 삭제될 아이템을 INSERT하거나, UPDATE하는 것은 낭비니까.

2.2 UPDATE 문 만을 사용하는 경우

CREATE TABLE Players 
( 
    UserID       VARCHAR(50)  NOT NULL, 
    Gold         INT          NOT NULL default '0', 
    X            INT          NOT NULL, 
    Y            INT          NOT NULL, 
    
    ...생략... 
 
    PRIMARY KEY(UserID) 
);

3 추가적인 고려사항

INSERT INTO ItemObject VALUES (0, "user1", 0, 10, 9);
UPDATE ItemObject SET X=0, Y=8 WHERE ItemID=0;
DELETE FROM ItemObject WHERE ItemID=0;
UPDATE ItemObject SET X=0, Y=8 WHERE ItemID=1;

4 소스

querybox.h

//////////////////////////////////////////////////////////////////////////////
/// \file QueryBox.h
/// \author excel96
/// \date 2004.4.29
//////////////////////////////////////////////////////////////////////////////

#ifndef __QUERYBOX_H__
#define __QUERYBOX_H__

#ifndef __NONCOPYABLE_H__
    #include "Noncopyable.h"
#endif

//////////////////////////////////////////////////////////////////////////////
/// \class FullQueryBox
/// \brief INSERT, UPDATE, DELETE 문을 다 사용하는 테이블에 대한 쿼리를 
/// 최적화하기 위해, 쿼리를 임시로 저장해 두는 버퍼 클래스.
//////////////////////////////////////////////////////////////////////////////

template <typename K>
class FullQueryBox : private Noncopyable
{
private:
    enum QueryEvent
    {
        QUERY_EVENT_INSERT = 0,
        QUERY_EVENT_UPDATE,
        QUERY_EVENT_DELETE,
        QUERY_EVENT_MAX
    };


private:
    typedef public stdext::hash_map<K, string> EVENT_MAP;
    EVENT_MAP m_pEventMap[QUERY_EVENT_MAX];


public:
    FullQueryBox() {}
    virtual ~FullQueryBox() { clear(); }


public:
    /// \brief 쿼리를 추가한다.
    void add(const K& key, const string& SQL)
    {
        Assert(!SQL.empty());

        QueryEvent QE     = QUERY_EVENT_MAX;
        string     header = SFCUtil::upper(SQL.substr(0, 6));

        // 쿼리문 앞부분 6글자로 쿼리의 종류를 판단한다.
        if (header == "INSERT") QE = QUERY_EVENT_INSERT;
        else if (header == "UPDATE") QE = QUERY_EVENT_UPDATE;
        else if (header == "DELETE") QE = QUERY_EVENT_DELETE;
        else Assert(false);

        // 쿼리의 종류에 따라 적당한 맵에다 집어넣어준다.
        EVENT_MAP& EM = m_pEventMap[QE];
        EVENT_MAP::iterator itr = EM.find(key);
        if (itr == EM.end()) { 
            EM.insert(EVENT_MAP::value_type(key, SQL)); 
        }
        else { 
            itr->second = SQL; 
        }
    }

    /// \brief 모든 쿼리를 삭제한다.
    void clear()
    {
        for (int i=0; i<QUERY_EVENT_MAX; i++)
            m_pEventMap[i].clear();
    }

    /// \brief 가지고 있는 SQL문이 하나도 없는지의 여부를 반환한다.
    bool empty() const
    {
        for (int i=0; i<QUERY_EVENT_MAX; i++)
            if (!m_pEventMap[i].empty()) return false;

        return true;
    }

    /// \brief 가지고 있는 SQL 문장들에 대해서 주어진 함수자를 실행한다.
    template <typename T>
    void for_each(T PRED) const
    {
        // 쿼리문을 생성하는 과정에 있어서 약간의 유의점이 필요한데, 
        // INSERT, UPDATE, DELETE의 순서대로 실행해야한다는 것이다.
        // 약간만 생각해보면 이유를 알 수 있을 것이다. 임의의 행을 UPDATE나 
        // DELETE하려면, INSERT가 우선 실행되어야 하기 때문이다.
        // 또한 DELETE할 행일 경우, INSERT나 UPDATE를 할 필요가 없다는 것도
        // 생각해야 한다.
        const EVENT_MAP& InsertMap = m_pEventMap[QUERY_EVENT_INSERT];
        const EVENT_MAP& DeleteMap = m_pEventMap[QUERY_EVENT_DELETE];
        for (int i=0; i<QUERY_EVENT_MAX; i++)
        {
            const EVENT_MAP& EM = m_pEventMap[i];
            for (EVENT_MAP::const_iterator itr(EM.begin());
                itr != EM.end(); itr++)
            {
                if (i == QUERY_EVENT_DELETE ||
                    DeleteMap.find(itr->first) == DeleteMap.end())
                {
                    PRED(itr->second);
                }
            }
        }
    }
};


//////////////////////////////////////////////////////////////////////////////
/// \class PartialQueryBox
/// \brief UPDATE 문 만을 사용하는 테이블에 대한 쿼리를 최적화하기 위해, 
/// 쿼리를 임시로 저장해 두는 버퍼 클래스.
//////////////////////////////////////////////////////////////////////////////

template <typename K>
class PartialQueryBox : private Noncopyable
{
private:
    typedef public stdext::hash_map<K, string> EVENT_MAP;
    EVENT_MAP m_EventMap;


public:
    PartialQueryBox() {}
    virtual ~PartialQueryBox() { clear(); }


public:
    /// \brief 쿼리를 추가한다.
    void add(const K& key, const string& SQL)
    {
        Assert(!SQL.empty());
        Assert(SFCUtil::upper(SQL.substr(0, 6)) == "UPDATE");

        EVENT_MAP::iterator itr(m_EventMap.find(key));
        if (itr == m_EventMap.end()) { 
            m_EventMap.insert(EVENT_MAP::value_type(key, SQL));
        }
        else {
            itr->second = SQL;
        }
    }

    /// \brief 모든 쿼리를 삭제한다.
    void clear() { m_EventMap.clear(); }

    /// \brief 가지고 있는 SQL문이 하나도 없는지의 여부를 반환한다.
    bool empty() const { return m_EventMap.empty(); }

    /// \brief 가지고 있는 SQL 문장들에 대해서 주어진 함수자를 실행한다.
    template <typename T>
    void for_each(T PRED) const
    {
        for (EVENT_MAP::const_iterator itr(m_EventMap.begin());
            itr != m_EventMap.end(); itr++)
        {
            PRED(itr->second);
        }
    }
};

#endif //__QUERYBOX_H__

사용법

/// 플레이어와 관련된 데이터베이스 변경 이벤트들
enum PlayerEvent
{
    PLAYER_EVENT_GOLD,  ///> 돈 변경
    PLAYER_EVENT_COORD, ///> 좌표 변경
    PLAYER_EVENT_MAX    ///> 배열을 위한 맥스값
};

typedef FullQueryBox<ItemID_t>       ITEM_BOX;
typedef PartialQueryBox<PlayerEvent> PLAYER_BOX;

struct FOR_EACH_QUERY
{
    list<string>& SQL_LIST;

    FOR_EACH_QUERY(list<string>& sl) 
        : SQL_LIST(sl) {}

    FOR_EACH_QUERY(const FOR_EACH_QUERY& other) 
        : SQL_LIST(other.SQL_LIST) {}

    void operator()(const string& SQL)
    {
        SQL_LIST.push_back(SQL);
    }
};

...

/// \brief 아이템 관련 쿼리를 생성해서 버퍼에다 집어넣는다.
void addItemQuery(ITEM_BOX& IB, Item* pItem, ...)
{
    IB.add(pItem->getItemID(), generateItemSQL(pItem, ...));
}

/// \brief 주기적으로 버퍼에 들어있는 쿼리들을 실행한다.
void save(ITEM_BOX& IB)
{
    ...
    
    list<string> sql_list;
    IB.for_each(FOR_EACH_QUERY(sql_list));
    IB.clear();
    
    for (list<string>::const_iterator itr(sql_list.begin());
        itr != sql_list.end(); itr++)
    {
        executeQuery(*itr, ...);
    }
    
    ...
}

5 문제점

CategoryDatabase

FindPage by browsing, title search , text search or an index
Or try one of these actions: AttachFile, DeletePage, LikePages, LocalSiteMap, RenamePage, SpellCheck

SeriousMoin v1 (koMoinMoin 1.0a4 Modified)