テーブル定義の変更と変換

Please execute the "create database" example before execute this example.

• 標準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>
#include <boost/bind.hpp>
using namespace bzs::db::protocol::tdap::client;
using namespace bzs::db::protocol::tdap;

/** @brief change schema and  convert table example

This program  change "user" table.
The "name" field is made into 64 characters from 32 characters.
And add The "tel" field.

Please execute the "create database" example before execute this example.

*/

static const short tablenum_user = 1;
static const short fieldnum_name = 1;

/** 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);
}

/** Change user table schema
 */
bool changeUserTable(dbdef* def)
{

    // change name size
    tabledef* td = def->tableDefs(tablenum_user);
    fielddef* fd = &td->fieldDefs[fieldnum_name];
    fd->setLenByCharnum(64);

    // add tel field
    fd = def->insertField(tablenum_user, td->fieldCount);
    fd->setName(_T("tel"));
    fd->type = ft_mychar;
    fd->setCharsetIndex(CHARSET_LATIN1);
    fd->setLenByCharnum(16);

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

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

void __STDCALL
    onCopyData(database* db, table* tb, int recordCount, int count, bool& cancel)
{
    if (count == 0)
        _tprintf(_T("\n"));
    _tprintf(_T("."));
}

#pragma argsused
int _tmain(int argc, _TCHAR* argv[])
{
    int result = 0;
    static const _TCHAR* uri = _T("tdap://localhost/test?dbfile=test.bdf");
    database* db = database::create();

    if (openDbExclusive(db, uri))
    {
        // backup current user table schema
        db->dbDef()->pushBackup(tablenum_user);
        if (db->dbDef()->stat() == 0)
        {
            if (changeUserTable(db->dbDef()))
            {
                // convert table if table exist;
                if (db->existsTableFile(TABLE_NUM_TMP, NULL))
                {
                    db->setOnCopyData(onCopyData);

                    db->convertTable(tablenum_user, false, NULL);
                    if (db->stat())
                        showError(_T("convert table"), NULL, db->stat());
                }
            }

            if (db->stat())
            {
                result = db->stat();
                // restore user table schema
                db->dbDef()->popBackup(tablenum_user);
            }
            else
                _tprintf(_T("\nchange schema success. \n"));
            
        }else
            showError(_T("backup table def"), NULL, db->dbDef()->stat());

        db->close();
    }
    database::destroy(db);
    return result;
}

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

#include <bzs/db/protocol/tdap/client/trdboostapi.h>
#include <iostream>
using namespace bzs::db::protocol::tdap::client;
using namespace bzs::db::protocol::tdap;

/**
@brief change schema and  convert table example

This program  change "user" table.
The "name" field is made into 64 characters from 32 characters.
And add The "tel" field.

Please execute the "create database" example before execute this example.

*/

static const short tablenum_user = 1;
static const short fieldnum_name = 1;

/** Change user table schema
 */
void changeUserTable(dbdef* def)
{
    // change name size
    tabledef* td = def->tableDefs(tablenum_user);
    fielddef* fd = &td->fieldDefs[fieldnum_name];
    fd->setLenByCharnum(64);

    // add tel field
    int size = lenByCharnum(ft_mychar, CHARSET_LATIN1, 16);
    fd = insertField(def, tablenum_user, td->fieldCount, _T("tel"), ft_mychar,
                     size);
    fd->setCharsetIndex(CHARSET_LATIN1);
    // write user table schema
    updateTableDef(def, tablenum_user);
}

void __STDCALL
    onCopyData(database* db, table* tb, int recordCount, int count, bool& cancel)
{
    if (count == 0)
        std::cout << std::endl;
    std::cout << ".";
}

#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);

        openDatabase(db, prams);

        // backup current user table schema
        db->dbDef()->pushBackup(tablenum_user);

        changeUserTable(db->dbDef());

        // convert table
        // If an error ouccered then restore the table schema automaticaly.
        convertTable(db, _T("user"), onCopyData);

        std::cout << "change schema success." << std::endl;
        return 0;
    }

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