Scimore Embedded database

Автор: Головко Георгий

Опубликовано:
Исправлено:

ПЛАН:

Для кого предназначена эта статья

Преимущества БД Scimore

Работа с БД

Шаг 1. Создаем БД

Шаг 2. Устанавливаем соединение с БД

Шаг 3. Выполняем запрос к СУБД

Шаг 4. Получаем данные из СУБД

Шаг 5. Вносим изменения в БД

Шаг 6. Производим поиск данных в БД

Шаг 7. Завершение работы

Демонстрационная программа (Исходные тексты)

Для кого предназначена эта статья

Если вы хотите узнать все преимущества и возможности СУБД Scimore а также как программно управлять данными в указанной СУБД, то эта статья для вас.

Преимущества БД Scimore

Работа с БД

Сначала в общих чертах.

§ Создать БД

§ Установить соединение с БД

§ Выполнить запрос

§ Получить данные

§ Внести изменения в БД (если необходимо)

§ Произвести поиск данных в БД (если необходимо)

§ Закрыть соединение

Теперь подробнее.

Шаг 1. Создаем БД

Для создания БД в первую очередь необходимо, чтобы в директории исполняемого модуля находились файлы Scimore.Data.dll и scimoredb.dll – динамические библиотеки для поддержки и взаимодействия с БД, а также в настройках проекта прописать путь к *.h – файлам из директории sdk и к библиотеке scdriver.lib из директории mtlib. Это необходимо, чтобы иметь доступ к пространству имен scdriver, которое и предоставляет возможности по взаимодействию с БД. Далее необходимо создать и запустить БД. Для этого создадим экземпляр класса c_scimore_db в классе представления:

public:

 c_scimore_db db;

Теперь можно создать и запустить БД, для этого пропишем следующий код:

void CEmbadedDBView::OpenDB(BOOL &DB)

{

// Если БД не существует, то установить и открыть ее

if (!IsDBInstalled())

{

try

{

db.install(DB);

db.close();

db.start(DB);

db.create_schema(DB);

}

// Обработка исключительной ситуации

catch (node_exception)

{

}

}

// Если БД существует открыть ее

else

db.start(DB);

}

Функция IsDBInstalled() ищет в директории исполняемого файла папку scimoreDB. Если она существует, это значит, что БД установлена, и она будет только открыта, в противном случае будет произведена ее установка.

Рассмотрим подробнее функции класса c_scimore_db:

1. Установка:

void install(BOOL &IsDB)

{

char path[MAX_PATH];

if(GetModuleFileNameA(NULL,path,MAX_PATH))

{

_TINT ch = TEXT('\\');

char *pfirst = strrchr(path, ch);

char *pnext = NULL;

// Search backward and replaces the dll name with the hook one

while(pfirst)

{

if(!(pnext = strrchr(pfirst + 1, ch)))

{

strcpy(&path[pfirst-path],"");

break;

}

else

pfirst = strrchr(path, ch);

}

// install embedded database

installDB(path, IsDB);

}

};

void installDB(const char *path, BOOL &IsDB)

{

char *net_conn = "-net/maxconn=8";

#ifdef SCIMORE_PROTO_TCP

char *net_edpn = "-net/endpoint=127.0.0.1:998";

char *net_prot = "-net/protocol=1";

#elif SCIMORE_PROTO_INPROC

char *net_edpn = "-net/endpoint=EmbadedDB";

char *net_prot = "-net/protocol=2";

#endif

char *tran_lock= "-tran/maxlocks=512";

char *tran_log = "-tran/logblocks=1";

char dllpath[MAX_PATH];

char db_sys1[MAX_PATH];

char db_sys2[MAX_PATH];

char db_sys3[MAX_PATH];

char *db_sys4 = "-db/cachepages=256";

sprintf(dllpath,"%s\\%s",path,"scimoreDB");

CreateDirectoryA(dllpath,0);

sprintf(db_sys1,"-db/systables=%s\\scimoredb",path);

sprintf(db_sys2,"-db/syslog=%s\\scimoredb",path);

sprintf(db_sys3,"-db/data=%s\\scimoredb",path);

sprintf(dllpath,"%s\\%s",path,"scimoreDB.dll");

char *param[9] = {net_conn,net_edpn,net_prot,tran_lock,tran_log,db_sys1,db_sys2,db_sys3,db_sys4};

// install embedded DB

SCIMORE_DB *dbInstall = 0;

//Load the dll and keep the handle to it

dllHandle = LoadLibraryA(dllpath);

// If the handle is valid, try to get the function address.

if (NULL != dllHandle)

{

//Get pointer to our function using GetProcAddress:

dbInstall = (SCIMORE_DB*)GetProcAddress(dllHandle, "DBInstall");

(*dbInstall)(9,param);

}

else IsDB = FALSE;

};

2. Запуск:

bool start(BOOL &IsDB)

{

static bool started = false;

if(!started)

{

char path[MAX_PATH];

if(GetModuleFileNameA(NULL,path,MAX_PATH))

{

_TINT ch = TEXT('\\');

char *pfirst = strrchr(path, ch);

char *pnext = NULL;

// Search backward and replaces the dll name with the hook one

while(pfirst)

{

if(!(pnext = strrchr(pfirst + 1, ch)))

{

strcpy(&path[pfirst-path],(""));

break;

}

else

pfirst = strrchr(path, ch);

}

if(!startDB(path, IsDB))

return false;

started = true;

}

}

return true;

};

bool startDB(const char *path, BOOL &IsDB)

{

char *net_conn = "-net/maxconn=8";

char *net_mode = "-net/mode=1";

#ifdef SCIMORE_PROTO_TCP

char *net_edpn = "-net/endpoint=127.0.0.1:998";

char *net_prot = "-net/protocol=1";

#elif SCIMORE_PROTO_INPROC

char *net_edpn = "-net/endpoint=EmbadedDB";

char *net_prot = "-net/protocol=2";

#endif

char *tran_lock= "-tran/maxlocks=512";

char *tran_log = "-tran/logblocks=1";

char *tran_chk = "-tran/LogCheckpoint=1";

char dllpath[MAX_PATH];

char db_sys1[MAX_PATH];

char db_sys2[MAX_PATH];

char db_sys3[MAX_PATH];

char *db_sys4 = "-db/cachepages=4096";

sprintf(db_sys1,"-db/systables=%s\\scimoredb",path);

sprintf(db_sys2,"-db/syslog=%s\\scimoredb",path);

sprintf(db_sys3,"-db/data=%s\\scimoredb",path);

sprintf(dllpath,"%s\\%s",path,"scimoreDB.dll");

char *param[11] = {net_conn,net_mode,net_edpn,net_prot,tran_lock,tran_log,tran_chk,db_sys1,db_sys2,db_sys3,db_sys4};

// install embedded DB

SCIMORE_DB *dbStart = 0;

//Load the dll and keep the handle to it

dllHandle = LoadLibraryA(dllpath);

// If the handle is valid, try to get the function address.

if (NULL != dllHandle)

{

//Get pointer to our function using GetProcAddress:

dbStart = (SCIMORE_DB*)GetProcAddress(dllHandle, "DBStart");

(*dbStart)(11,param);

// set in_process default protocol

#ifdef SCIMORE_PROTO_TCP

set_default_prot(1);

#elif SCIMORE_PROTO_INPROC

set_default_prot(2);

#endif

return true;

}

IsDB = FALSE;

return false;

};

3. Создание концептуальной схемы:

void create_schema(BOOL &IsDB)

{

#ifdef SCIMORE_PROTO_TCP

char* host = "localhost";

#elif SCIMORE_PROTO_INPROC

char* host = "EmbadedDB";

#endif

CConnection conn;

try

{

conn.Connect(host, 998);

}

catch (node_exception& e)

{

MessageBoxA(0, e.msg, "Attention", MB_OK | MB_ICONERROR);

}

try

{

// Создадим БД

conn.Execute("CREATE DATABASE IF NOT EXISTS SALES");

conn.GetCompletionStatus();

conn.Execute("USE SALES");

conn.GetCompletionStatus();

// Создадим таблицу учета Продуктов

conn.Execute("CREATE TABLE IF NOT EXISTS PRODUCT("

"ID BIGINT NOT NULL PRIMARY KEY, "

"NAME VARCHAR(255) NOT NULL, "

"PRICE DOUBLE NOT NULL, "

"FIRM VARCHAR(255) NOT NULL, "

"SLIFE VARCHAR(32))");

conn.GetCompletionStatus();

// Создадим таблицу учета Покупателей

conn.Execute("CREATE TABLE IF NOT EXISTS CUSTOMER("

"ID BIGINT NOT NULL PRIMARY KEY, "

"FNAME VARCHAR(255) NOT NULL, "

"LNAME VARCHAR(255), "

"ADDRESS VARCHAR(255) NOT NULL, "

"YBORN DATETIME)");

conn.GetCompletionStatus();

// Создадим таблицу учета Продаж

conn.Execute("CREATE TABLE IF NOT EXISTS SALE("

"ID BIGINT NOT NULL PRIMARY KEY, "

"PID BIGINT NOT NULL, "

"CID BIGINT NOT NULL, "

"DATE DATETIME NOT NULL, "

"TSUM DOUBLE NOT NULL, "

"CONSTRAINT FKP FOREIGN KEY (PID) REFERENCES PRODUCT(ID), "

"CONSTRAINT FKC FOREIGN KEY (CID) REFERENCES CUSTOMER(ID))");

conn.GetCompletionStatus();

conn.Close();

}

catch (node_exception& e)

{

MessageBoxA(0, e.msg, "Attention", MB_OK | MB_ICONERROR);

IsDB = FALSE;

}

};

Шаг 2. Устанавливаем соединение с БД

Прежде чем начать работать, нам необходимо установить соединение с БД. Для этих целей служит пространство имен scdriver, объявление и интерфейс которого находится в файле scdriver.h из директории sdk. А именно, воспользуемся средствами класса CConnection, посредством которого мы и будем устанавливать соединение и управление записями в БД. Для примера возьмем создание концептуальной схемы из предыдущего шага.

Чтобы программно обращаться к БД, необходимо в директивах препроцессора настроек проекта определить одно из макроопределений: SCIMORE_PROTO_TCP – для обращения посредством протокола TCP или SCIMORE_PROTO_INPROC – для обращения через алиас.

Теперь, в зависимости от объявленного макроопределения, мы можем формировать адрес узла и порт, посредством которых будет происходить обращение к БД:

#ifdef SCIMORE_PROTO_TCP

char* host = "localhost";

#elif SCIMORE_PROTO_INPROC

char* host = "EmbadedDB";

#endif

Теперь можно создать экземпляр класса CConnection:

CConnection conn;

И установить соединение:

try

{

conn.Connect(host, 998);

}

catch (node_exception& e)

{

MessageBoxA(0, e.msg, "Attention", MB_OK | MB_ICONERROR);

}

После выполнения необходимых действий, соединение с БД необходимо завершить. Для этого выполним следующий код:

conn.Close();

Шаг 3. Выполняем запрос к СУБД

Выполним запрос к созданной ранее БД (см. Шаг 1 – Создание концептуальной схемы). Рассмотрим запрос на примере получения данных из БД и вывода их на экран в таблицу. Для этого нам необходимо создать экземпляр класса CConnection:

CConnection conn;

Теперь необходимо выполнить подключение к БД. Для этого выполним следующий код:

int CMyTable::Connect(CConnection* conn)

{

#ifdef SCIMORE_PROTO_TCP

char* host = "localhost";

#elif SCIMORE_PROTO_INPROC

char* host = "EmbadedDB";

#endif

try

{

// Подключение к узлу по указанному порту

conn->Connect(host, 998);

// Использование БД SALES

conn->Execute("USE SALES");

conn->GetCompletionStatus();

}

// Обработка исключительной ситуации

catch(node_exception& e)

{

MessageBoxA(0, e.msg, "Attention", MB_OK | MB_ICONERROR);

return 0;

}

return 1;

}

Где входной параметр CConnection* conn является указателем на ранее объявленный объект класса CConnection. Мы используем конструкцию try