started work

Author: Gazizonoki

CMakeLists.txt

@@ -10,6 +10,7 @@ project(YDB-CPP-SDK VERSION ${YDB_SDK_VERSION} LANGUAGES C CXX ASM)
 option(YDB_SDK_INSTALL "Install YDB C++ SDK" Off)
 option(YDB_SDK_TESTS "Build YDB C++ SDK tests" Off)
 option(YDB_SDK_EXAMPLES "Build YDB C++ SDK examples" On)
+option(YDB_SDK_ODBC "Build YDB ODBC driver" On)
 set(YDB_SDK_GOOGLE_COMMON_PROTOS_TARGET "" CACHE STRING "Name of cmake target preparing google common proto library")
 option(YDB_SDK_USE_RAPID_JSON "Search for rapid json library in system" ON)
 
@@ -62,6 +63,10 @@ add_subdirectory(util)
 
 #_ydb_sdk_validate_public_headers()
 
+if (YDB_SDK_ODBC)
+  add_subdirectory(odbc)
+endif()
+
 if (YDB_SDK_EXAMPLES)
   add_subdirectory(examples)
 endif()

odbc/CMakeLists.txt

@@ -0,0 +1,64 @@
+cmake_minimum_required(VERSION 3.14)
+project(ydb-odbc VERSION 0.1.0 LANGUAGES C CXX)
+
+set(CMAKE_CXX_STANDARD 20)
+set(CMAKE_CXX_STANDARD_REQUIRED ON)
+set(CMAKE_CXX_EXTENSIONS OFF)
+
+# Находим зависимости
+find_package(ODBC REQUIRED)
+
+# Добавляем исходники
+add_library(ydb-odbc SHARED
+  src/driver.c
+  src/connection.c
+  src/statement.c
+  src/descriptor.c
+  src/client/driver.cpp
+  src/client/query.cpp
+)
+
+# Добавляем заголовочные файлы
+target_include_directories(ydb-odbc
+  PUBLIC
+    ${CMAKE_CURRENT_SOURCE_DIR}/include
+    ${ODBC_INCLUDE_DIRS}
+    /usr/include
+    /usr/local/include
+)
+
+# Линкуем с YDB SDK и ODBC
+target_link_libraries(ydb-odbc
+  PUBLIC
+    YDB-CPP-SDK::Query
+    YDB-CPP-SDK::Table
+    YDB-CPP-SDK::Driver
+    ODBC::ODBC
+)
+
+# Устанавливаем драйвер
+install(TARGETS ydb-odbc
+  LIBRARY DESTINATION ${CMAKE_INSTALL_LIBDIR}
+)
+
+# Устанавливаем заголовочные файлы
+install(DIRECTORY include/
+  DESTINATION include/ydb-odbc
+)
+
+# Добавляем тесты
+# add_subdirectory(tests)
+
+# Правила установки
+include(GNUInstallDirs)
+
+install(FILES 
+  odbcinst.ini
+  DESTINATION ${CMAKE_INSTALL_SYSCONFDIR}/odbcinst.d
+  RENAME ydb-odbc.ini
+)
+
+install(FILES
+  odbc.ini
+  DESTINATION ${CMAKE_INSTALL_SYSCONFDIR}
+)

odbc/README.md

@@ -0,0 +1,105 @@
+# YDB ODBC Driver
+
+ODBC драйвер для YDB.
+
+## Требования
+
+- CMake 3.10 или выше
+- Компилятор C/C++ с поддержкой C11 и C++20
+- YDB C++ SDK
+- unixODBC (для Linux/macOS)
+
+## Сборка
+
+```bash
+mkdir build && cd build
+cmake ..
+make
+```
+
+## Установка
+
+```bash
+sudo make install
+```
+
+Это установит:
+- Библиотеку драйвера в `/usr/local/lib/`
+- Конфигурацию драйвера в `/etc/odbcinst.d/`
+- Конфигурацию источников данных в `/etc/odbc.ini`
+
+## Настройка
+
+1. Убедитесь, что драйвер зарегистрирован:
+```bash
+odbcinst -q -d
+```
+
+2. Проверьте доступные источники данных:
+```bash
+odbcinst -q -s
+```
+
+3. Отредактируйте `/etc/odbc.ini` для настройки подключения:
+```ini
+[YDB]
+Driver=YDB
+Description=YDB Database Connection
+Server=grpc://your-server:2136
+Database=your-database
+AuthMode=none  # или token для аутентификации по токену
+```
+
+## Использование
+
+Пример подключения через isql:
+```bash
+isql -v YDB
+```
+
+Пример использования в C:
+```c
+SQLHENV env;
+SQLHDBC dbc;
+SQLHSTMT stmt;
+
+// Инициализация окружения
+SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &env);
+SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
+
+// Подключение
+SQLAllocHandle(SQL_HANDLE_DBC, env, &dbc);
+SQLConnect(dbc, (SQLCHAR*)"YDB", SQL_NTS,
+          (SQLCHAR*)"", SQL_NTS,
+          (SQLCHAR*)"", SQL_NTS);
+
+// Выполнение запроса
+SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt);
+SQLExecDirect(stmt, (SQLCHAR*)"SELECT * FROM mytable", SQL_NTS);
+
+// Очистка
+SQLFreeHandle(SQL_HANDLE_STMT, stmt);
+SQLDisconnect(dbc);
+SQLFreeHandle(SQL_HANDLE_DBC, dbc);
+SQLFreeHandle(SQL_HANDLE_ENV, env);
+```
+
+## Поддерживаемые функции
+
+- SQLAllocHandle
+- SQLConnect
+- SQLDisconnect
+- SQLExecDirect
+- SQLFetch
+- SQLGetData
+- SQLPrepare
+- SQLExecute
+- SQLCloseCursor
+- SQLFreeHandle
+- SQLGetInfo
+- SQLGetDescField
+- SQLSetDescField
+
+## Лицензия
+
+Apache License 2.0 

odbc/include/client/driver.h

@@ -0,0 +1,15 @@
+#pragma once
+
+#include <stddef.h> // для size_t
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+// Функции для работы с YDB через C++ SDK
+void* YDB_CreateDriver(const char* endpoint, const char* user, const char* password);
+void YDB_DestroyDriver(void* driver);
+
+#ifdef __cplusplus
+}
+#endif

odbc/include/client/query.h

@@ -0,0 +1,17 @@
+#pragma once
+
+#include <stddef.h>
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+void* YDB_CreateQueryClient(void* driver);
+void YDB_DestroyQueryClient(void* query_client);
+
+int YDB_ExecuteQuery(void* query_client, const char* query, void** result);
+void YDB_FreeExecuteQueryResult(void* result);
+
+#ifdef __cplusplus
+}
+#endif

odbc/include/ydb_odbc.h

@@ -0,0 +1,89 @@
+#pragma once
+
+#include <sql.h>
+#include <sqlext.h>
+#include <stddef.h>
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+// Структура для хранения информации о драйвере
+typedef struct {
+    char name[256];
+    char version[64];
+    char description[1024];
+} YDB_DRIVER_INFO;
+
+// Структура для хранения состояния соединения
+typedef struct {
+    void* ydb_driver;
+    void* query_client;
+    int connected;
+} YDB_CONNECTION;
+
+// Структура для хранения состояния оператора
+typedef struct {
+    YDB_CONNECTION* connection;
+    void* query_client;
+    void* result;
+    size_t current_row;
+} YDB_STATEMENT;
+
+// Структура для хранения дескриптора
+typedef struct {
+    void** descriptors;
+    size_t descriptors_size;
+} YDB_DESCRIPTOR;
+
+// Функции драйвера
+SQLRETURN YDB_SQLGetInfo(SQLSMALLINT InfoType, SQLPOINTER InfoValue,
+                        SQLSMALLINT BufferLength, SQLSMALLINT* StringLength);
+
+SQLRETURN YDB_SQLConnect(SQLHDBC ConnectionHandle, SQLCHAR* ServerName,
+                        SQLSMALLINT NameLength1, SQLCHAR* UserName,
+                        SQLSMALLINT NameLength2, SQLCHAR* Authentication,
+                        SQLSMALLINT NameLength3);
+
+SQLRETURN YDB_SQLDriverConnect(SQLHDBC ConnectionHandle, SQLHWND WindowHandle,
+                             SQLCHAR* InConnectionString, SQLSMALLINT StringLength1,
+                             SQLCHAR* OutConnectionString, SQLSMALLINT BufferLength,
+                             SQLSMALLINT* StringLength2, SQLUSMALLINT DriverCompletion);
+
+// Функции соединения
+SQLRETURN YDB_SQLDisconnect(SQLHDBC ConnectionHandle);
+
+SQLRETURN YDB_SQLGetConnectionInfo(SQLHDBC ConnectionHandle, SQLSMALLINT InfoType,
+                                 SQLPOINTER InfoValue, SQLSMALLINT BufferLength,
+                                 SQLSMALLINT* StringLength);
+
+SQLRETURN YDB_SQLAllocHandle(SQLSMALLINT HandleType, SQLHANDLE InputHandle,
+                           SQLHANDLE* OutputHandle);
+
+SQLRETURN YDB_SQLFreeHandle(SQLSMALLINT HandleType, SQLHANDLE Handle);
+
+// Функции оператора
+SQLRETURN YDB_SQLExecDirect(SQLHSTMT StatementHandle, SQLCHAR* StatementText,
+                          SQLINTEGER TextLength);
+
+SQLRETURN YDB_SQLPrepare(SQLHSTMT StatementHandle, SQLCHAR* StatementText,
+                        SQLINTEGER TextLength);
+
+SQLRETURN YDB_SQLExecute(SQLHSTMT StatementHandle);
+
+SQLRETURN YDB_SQLFetch(SQLHSTMT StatementHandle);
+
+SQLRETURN YDB_SQLCloseCursor(SQLHSTMT StatementHandle);
+
+// Функции дескриптора
+SQLRETURN YDB_SQLGetDescField(SQLHDESC DescriptorHandle, SQLSMALLINT RecNumber,
+                            SQLSMALLINT FieldIdentifier, SQLPOINTER Value,
+                            SQLINTEGER BufferLength, SQLINTEGER* StringLength);
+
+SQLRETURN YDB_SQLSetDescField(SQLHDESC DescriptorHandle, SQLSMALLINT RecNumber,
+                            SQLSMALLINT FieldIdentifier, SQLPOINTER Value,
+                            SQLINTEGER BufferLength);
+
+#ifdef __cplusplus
+}
+#endif

odbc/odbc.ini

@@ -0,0 +1,9 @@
+[ODBC Data Sources]
+YDB=YDB ODBC Driver
+
+[YDB]
+Driver=YDB
+Description=YDB Database Connection
+Server=grpc://localhost:2136
+Database=local
+AuthMode=none 

odbc/odbcinst.ini

@@ -0,0 +1,7 @@
+[YDB]
+Description=YDB ODBC Driver
+Driver=/usr/local/lib/libydb-odbc.so
+Setup=/usr/local/lib/libydb-odbc.so
+Threading=2
+FileUsage=1
+UsageCount=1

odbc/src/client/driver.cpp

@@ -0,0 +1,25 @@
+#include "client/driver.h"
+
+#include <ydb-cpp-sdk/client/driver/driver.h>
+
+extern "C" {
+
+void* YDB_CreateDriver(const char* endpoint, const char* user, const char* password) {
+    try {
+        auto config = NYdb::TDriverConfig().SetEndpoint(std::string(endpoint, strlen(endpoint)));
+
+        auto* driver = new NYdb::TDriver(config);
+        return static_cast<void*>(driver);
+    } catch (...) {
+        return nullptr;
+    }
+}
+
+void YDB_DestroyDriver(void* driver) {
+    if (driver) {
+        auto* ydb_driver = static_cast<NYdb::TDriver*>(driver);
+        delete ydb_driver;
+    }
+}
+
+}