データベースとテーブルの作成

• 標準APIを使ったサンプル
• コンビニエンスAPIを使ったサンプル

標準APIを使ったサンプル

#include <stdio.h>
#include <bzs/db/protocol/tdap/client/database.h>
#include <bzs/db/protocol/tdap/client/table.h>
#include <bzs/db/protocol/tdap/client/dbDef.h>

using namespace bzs::db::protocol::tdap::client;
using namespace bzs::db::protocol::tdap;

/**
@brief create database example

This program  create "test" database and
"test" table. The table of "test" has schema data.
And it call "schema table".

database name :  'test'

table 'user'  tableid = 1
   -------------------------------------------------
   No.| Filed name  | type    |  size
   -------------------------------------------------
   0  |  id         | integer | 4byte
   1  |  name       | var     | 97byte (32 charctors)
   2  |  groupid    | integer | 4byte
   -------------------------------------------------
   -------------------------------------------------
   index No.|  type  | segment0(size) | segment1(size)
   -------------------------------------------------
   0        | primary| id(4)          |  -
   1        |        | groupid(4)     |  -



table 'group1' tableid = 2
   -------------------------------------------------
   No.| Filed name  | type    |  size
   -------------------------------------------------
   0  |  id         | integer | 4byte
   1  |  name       | var     | 97byte (32 charctors)
   -------------------------------------------------
   -------------------------------------------------
   index No.|  type  | segment0(size) | segment1(size)
   -------------------------------------------------
   0        | primary| id(4)          |  -


table 'picture' tableid = 3
   -------------------------------------------------
   No.| Filed name  | type    |  size
   -------------------------------------------------
   0  |  type       | integer | 2byte
   0  |  id         | integer | 4byte
   1  |  picture    | myblob  | 11 MIDIUMBLOB
   -------------------------------------------------
   -------------------------------------------------
   index No.|  type  | segment0(size) | segment1(size)
   -------------------------------------------------
   0        | primary| type(2)        |  id(4)


*/

/** show database operation error
*/
void showError(const _TCHAR* caption, const _TCHAR* tableName, short statusCode)
{
    _TCHAR tmp[1024] = { 0x00 };
    nstable::tdapErr(0x00, statusCode, tableName, tmp);
    _tprintf(_T("[ERROR] %s No.%ld %s\n"), caption, statusCode, tmp);
}

/** Create mysql database and empty schema table
 */
bool createBatabase(database* db, const _TCHAR* uri)
{
    db->create(uri);
    if (db->stat() != 0)
    {
        showError(_T("createDatabse"), NULL, db->stat());
        return false;
    }
    return true;
}

/** Open database and empty schema table
 */
bool openDbExclusive(database* db, const _TCHAR* uri)
{
    db->open(uri, TYPE_SCHEMA_BDF, TD_OPEN_EXCLUSIVE);
    if (db->stat() != 0)
    {
        showError(_T("openBatabase"), NULL, db->stat());
        return false;
    }
    return true;
}

/** Create user table schema and write
 */
bool createUserTableSchema(dbdef* def)
{

    // Insert table
    tabledef td;
    td.setTableName(_T("user"));
    td.setFileName(_T("user.dat"));
    td.id = 1;
    td.charsetIndex = CHARSET_UTF8B4;
    def->insertTable(&td);
    if (def->stat() != 0)
    {
        showError(_T("create schema table user"), NULL, def->stat());
        return false;
    }

    // Insert field
    short fieldNum = 0;
    fielddef* fd = def->insertField(td.id, fieldNum);
    fd->setName(_T("id"));
    fd->type = ft_integer;
    fd->len = (ushort_td)4;

    fd = def->insertField(td.id, ++fieldNum);
    fd->setName(_T("name"));
    fd->type = ft_myvarchar;
    fd->setLenByCharnum(32);

    fd = def->insertField(td.id, ++fieldNum);
    fd->setName(_T("group"));
    fd->type = ft_integer;
    fd->len = (ushort_td)4;

    // Insert index
    uchar_td keyNum = 0;
    keydef* kd = def->insertKey(td.id, keyNum);
    kd->segments[0].fieldNum = 0;
    kd->segments[0].flags.bit8 = true; // extended type
    kd->segments[0].flags.bit1 = true; // updateable
    kd->segmentCount = 1;
    def->tableDefs(td.id)->primaryKeyNum = keyNum;

    keyNum = 1;
    kd = def->insertKey(td.id, keyNum);
    kd->segments[0].fieldNum = 2; // groupid
    kd->segments[0].flags.bit8 = true; // extended type
    kd->segments[0].flags.bit1 = true; // updateable
    kd->segments[0].flags.bit0 = true; // duplicateable
    kd->segmentCount = 1;

    // write schema table
    def->updateTableDef(td.id);
    if (def->stat() != 0)
    {
        showError(_T("edit schema table"), NULL, def->stat());
        return false;
    }
    return true;
}

/** Create group table schema and write
 */
bool createGroupTableSchema(dbdef* def)
{

    // Insert table
    tabledef td;
    td.setTableName(_T("group1"));
    td.setFileName(_T("group1.dat"));
    td.id = 2;
    td.charsetIndex = CHARSET_UTF8B4;
    def->insertTable(&td);
    if (def->stat() != 0)
    {
        showError(_T("create schema table group1"), NULL, def->stat());
        return false;
    }

    // Insert field
    short fieldNum = 0;
    fielddef* fd = def->insertField(td.id, fieldNum);
    fd->setName(_T("id"));
    fd->type = ft_integer;
    fd->len = (ushort_td)4;

    fd = def->insertField(td.id, ++fieldNum);
    fd->setName(_T("name"));
    fd->type = ft_myvarchar;
    fd->setLenByCharnum(32);

    // Insert index
    uchar_td keyNum = 0;
    keydef* kd = def->insertKey(td.id, keyNum);
    kd->segments[0].fieldNum = 0;
    kd->segments[0].flags.bit8 = true; // extended type
    kd->segments[0].flags.bit1 = true; // updateable
    kd->segmentCount = 1;
    def->tableDefs(td.id)->primaryKeyNum = keyNum;

    // write schema table
    def->updateTableDef(td.id);
    if (def->stat() != 0)
    {
        showError(_T("edit schema table"), NULL, def->stat());
        return false;
    }
    return true;
}

/** Create picture table schema and write
 */
bool createPictureTableSchema(dbdef* def)
{
    // Insert table
    tabledef td;
    td.setTableName(_T("picture"));
    td.setFileName(_T("picture.dat"));
    td.id = 3;
    td.charsetIndex = CHARSET_LATIN1;
    def->insertTable(&td);
    if (def->stat() != 0)
    {
        showError(_T("create schema table picture"), NULL, def->stat());
        return false;
    }

    // Insert 3 fields
    short fieldNum = 0;
    fielddef* fd = def->insertField(td.id, fieldNum);
    fd->setName(_T("type"));
    fd->type = ft_integer;
    fd->len = (ushort_td)2;

    fd = def->insertField(td.id, ++fieldNum);
    fd->setName(_T("id"));
    fd->type = ft_integer;
    fd->len = (ushort_td)4;

    fd = def->insertField(td.id, ++fieldNum);
    fd->setName(_T("picture"));
    fd->type = ft_myblob;
    fd->len = (ushort_td)11;

    // Insert index
    uchar_td keyNum = 0;
    keydef* kd = def->insertKey(td.id, keyNum);
    keySegment* ks = &kd->segments[0];
    ks->fieldNum = 0; // type
    ks->flags.bit8 = true; // extended type
    ks->flags.bit1 = true; // updateable
    ks->flags.bit4 = true; // segment part

    ks = &kd->segments[1];
    ks->fieldNum = 1; // id
    ks->flags.bit8 = true; // extended type
    ks->flags.bit1 = true; // updateable

    kd->segmentCount = 2;
    def->tableDefs(td.id)->primaryKeyNum = keyNum;

    // write schema table
    def->updateTableDef(td.id);
    if (def->stat() != 0)
    {
        showError(_T("edit schema table"), NULL, def->stat());
        return false;
    }
    return true;
}

#pragma argsused
int _tmain(int argc, _TCHAR* argv[])
{

    int result = 1;
    static const _TCHAR* uri = _T("tdap://localhost/test?dbfile=test.bdf");

    database* db = database::create();
    if (createBatabase(db, uri))
    {
        if (openDbExclusive(db, uri))
        {
            if (createUserTableSchema(db->dbDef()))
            {
                if (createGroupTableSchema(db->dbDef()))
                {
                    if (createPictureTableSchema(db->dbDef()))
                    {
                        _tprintf(_T("create databse success. \n"));
                        result = 0;
                    }
                }
            }
            db->close();
        }
    }
    database::destroy(db);
    return result;
}

コンビニエンスAPIを使ったサンプル

#include <bzs/db/protocol/tdap/client/trdboostapi.h>
#include <iostream>
#include <bzs/env/tstring.h>

using namespace bzs::db::protocol::tdap::client;
using namespace bzs::db::protocol::tdap;

/**
@brief create database example

This program  create "test" database and
"test" table. The table of "test" has schema data.
And it is called "schema table".


database name :  'test'

table 'user'  tableid = 1
   -------------------------------------------------
   No.| Filed name  | type    |  size
   -------------------------------------------------
   0  |  id         | integer | 4byte
   1  |  name       | var     | 97byte (32 charctors)
   2  |  groupid    | integer | 4byte
   -------------------------------------------------
   -------------------------------------------------
   index No.|  type  | segment0(size) | segment1(size)
   -------------------------------------------------
   0        | primary| id(4)          |  -
   1        |        | groupid(4)     |  -



table 'group1' tableid = 2
   -------------------------------------------------
   No.| Filed name  | type    |  size
   -------------------------------------------------
   0  |  id         | integer | 4byte
   1  |  name       | var     | 97byte (32 charctors)
   -------------------------------------------------
   -------------------------------------------------
   index No.|  type  | segment0(size) | segment1(size)
   -------------------------------------------------
   0        | primary| id(4)          |  -


table 'picture' tableid = 3
   -------------------------------------------------
   No.| Filed name  | type    |  size
   -------------------------------------------------
   0  |  type       | integer | 2byte
   0  |  id         | integer | 4byte
   1  |  picture    | myblob  | 11 MIDIUMBLOB
   -------------------------------------------------
   -------------------------------------------------
   index No.|  type  | segment0(size) | segment1(size)
   -------------------------------------------------
   0        | primary| type(2)        |  id(4)


*/

/** Create user table schema and write
 */
void createUserTableSchema(dbdef* def)
{
    // Insert table
    short tableid = 1;
    const _TCHAR* name = _T("user");
    insertTable(def, tableid, name, CHARSET_UTF8B4);

    // Insert 3 fields
    short fieldNum = 0;
    insertField(def, tableid, fieldNum, _T("id"), ft_integer, 4);

    int size = lenByCharnum(ft_myvarchar, CHARSET_UTF8B4, 32);
    insertField(def, tableid, ++fieldNum, _T("name"), ft_myvarchar, size);
    insertField(def, tableid, ++fieldNum, _T("group"), ft_integer, 4);

    // Insert index
    uchar_td keyNum = 0;
    keydef* kd = insertKey(def, tableid, keyNum);
    keySegment* ks = &kd->segments[0];
    ks->fieldNum = 0; // id
    ks->flags.bit8 = true; // extended type
    ks->flags.bit1 = true; // updateable
    kd->segmentCount = 1;
    def->tableDefs(tableid)->primaryKeyNum = keyNum;

    keyNum = 1;
    kd = insertKey(def, tableid, keyNum);
    ks = &kd->segments[0];
    ks->fieldNum = 2; // groupid
    ks->flags.bit8 = true; // extended type
    ks->flags.bit1 = true; // updateable
    ks->flags.bit0 = true; // duplicateable
    kd->segmentCount = 1;

    // write schema table
    updateTableDef(def, tableid);
}

/** Create group table schema and write
 */
void createGroupTableSchema(dbdef* def)
{
    // Insert table
    short tableid = 2;
    const _TCHAR* name = _T("group1");
    insertTable(def, tableid, name, CHARSET_UTF8B4);

    // Insert 2 fields
    short fieldNum = 0;
    insertField(def, tableid, fieldNum, _T("id"), ft_integer, 4);
    int size = lenByCharnum(ft_myvarchar, CHARSET_UTF8B4, 32);
    insertField(def, tableid, ++fieldNum, _T("name"), ft_myvarchar, size);

    // Insert index
    uchar_td keyNum = 0;
    keydef* kd = insertKey(def, tableid, keyNum);
    keySegment* ks = &kd->segments[0];
    ks->fieldNum = 0; // id
    ks->flags.bit8 = true; // extended type
    ks->flags.bit1 = true; // updateable
    kd->segmentCount = 1;
    def->tableDefs(tableid)->primaryKeyNum = keyNum;
    // write schema table
    updateTableDef(def, tableid);
}

/** Create picture table schema and write
 */
void createPictureTableSchema(dbdef* def)
{
    // Insert table
    short tableid = 3;
    const _TCHAR* name = _T("picture");
    insertTable(def, tableid, name, CHARSET_LATIN1);

    // Insert 3 fields
    short fieldNum = 0;

    insertField(def, tableid, fieldNum, _T("type"), ft_integer, 2);
    insertField(def, tableid, ++fieldNum, _T("id"), ft_integer, 4);
    insertField(def, tableid, ++fieldNum, _T("picture"), ft_myblob, 11);

    // Insert index
    uchar_td keyNum = 0;
    keydef* kd = insertKey(def, tableid, keyNum);
    keySegment* ks = &kd->segments[0];
    ks->fieldNum = 0; // type
    ks->flags.bit8 = true; // extended type
    ks->flags.bit1 = true; // updateable
    ks->flags.bit4 = true; // segment part

    ks = &kd->segments[1];
    ks->fieldNum = 1; // id
    ks->flags.bit8 = true; // extended type
    ks->flags.bit1 = true; // updateable

    kd->segmentCount = 2;
    def->tableDefs(tableid)->primaryKeyNum = keyNum;

    // write schema table
    updateTableDef(def, tableid);
}

#pragma argsused
int _tmain(int argc, _TCHAR* argv[])
{
    database_ptr db = createDatabaseObject();
    try
    {
        connectParams prams(_T("tdap"), _T("localhost"), _T("test"),
                            _T("test"));
        prams.setMode(TD_OPEN_EXCLUSIVE);

        createDatabase(db, prams);

        openDatabase(db, prams);

        createUserTableSchema(db->dbDef());

        createGroupTableSchema(db->dbDef());

        createPictureTableSchema(db->dbDef());

        std::cout << "create databse success." << std::endl;
        return 0;
    }

    catch (bzs::rtl::exception& e)
    {
        std::tcout << _T("[ERROR] ") << *bzs::rtl::getMsg(e) << std::endl;
    }
    return 1;
}