ODBC

• 安装 unixODBC 库

  apt-get install unixodbc unixodbc-dev

• 安装 SQL Server ODBC 驱动

  apt-get install tdsodbc

• 安装 PostgreSQL ODBC 驱动

  apt-get install odbc-postgresql

• 安装 MySQL ODBC 驱动

  apt-get install libmyodbc

• 安装 SQLite ODBC 驱动

  apt-get install libsqliteodbc

# 安装 unixODBC 库
yum install unixODBC  unixODBC-devel

# 安装 MySQL ODBC 驱动
yum install mysql-connector-odbc

从官网下载并安装 MySQL 或其他数据库的 ODBC 驱动程序。示例如下：

• MySQL：https://dev.mysql.com/downloads/connector/odbc/
• MS SQL Server：https://www.microsoft.com/en-us/download/details.aspx?id=53339
• PostgreSQL：https://www.postgresql.org/ftp/odbc/versions/msi/

• 配置 ODBC 数据源。例如，在 Windows 操作系统中配置 MySQL 的 ODBC 数据源的操作指导，可以参考： MySQL manual。

运行以下命令安装 unixODBC 库：

# 安装 unixODBC 库
apk add unixodbc
apk add unixodbc-dev

DolphinDB Server: 2.00.10及更高版本。支持 Linux x86, Linux ABI, Linux JIT, Windows, Windows JIT。

1. 在 DolphinDB 客户端中使用 listRemotePlugins 命令查看插件仓库中的插件信息。

   注意：仅展示当前操作系统和 server 版本支持的插件。若无预期插件，可自行编译（请自行选择对应分支下的插件）或在 DolphinDB 用户社区进行反馈。

   login("admin", "123456")
   listRemotePlugins()

2. 使用 installPlugin 命令完成插件安装。

   installPlugin("odbc")

3. 使用 loadPlugin 命令加载插件。

   loadPlugin("odbc")

注意：若在 Alpine Linux 环境中使用插件，加载时可能会出现无法找到依赖库的报错，需要在 DolphinDB 的 server 目录下添加软链接：ln -s /usr/lib/libodbc.so.2 libodbc.so.1

语法

odbc::connect(connStr, [dataBaseType])

详情

创建与数据库服务器的连接，返回数据库连接句柄，该句柄将在以后用于访问数据库服务器。

参数

connStr ODBC 连接字符串。有关连接字符串格式的更多信息，请参阅 连接字符串参考。ODBC DSN 必须由系统管理员创建。

有关 DSN 连接字符串的更多信息，请参阅 DSN连接字符串。我们还可以创建到数据库的 DSN-Less 连接。

如果不通过 DSN 配置方式，可以在连接字符串中指定驱动程序名称和所有特定于驱动程序的信息，例如：SQL server 的 DSN-less 连接字符串或 MySQL 的 DSN-less 连接字符串。

dataBaseType 数据库类型。如 "MySQL", "SQLServer", "PostgreSQL", "ClickHouse", "SQLite", "Oracle" 不区分大小写。建议连接时指定该参数，否则写入数据时可能出现报错。

注意：

• 驱动程序名称可能会有所不同，具体取决于安装的 ODBC 版本。
• 若数据库连接的端口指定错误，则会出现 server crash。
• 必须通过 DSN 方式连接 Oracle 数据源，否则连接时用户名和密码可能校验失败；若修改 /etc/odbc.ini 中 DSN 配置的 database 和 password，则需要在 Oracle 命令行中 commit 后才能通过新配置进行连接（也可通过 isql 命令行工具验证配置是否生效）。
• 通过 freeTDS 访问数据库时，必须保证 freetds.conf 中的 DSN 配置信息正确，否则可能出现 freeTDS crash 的情况。

例子

conn1 = odbc::connect("Dsn=mysqlOdbcDsn")  //mysqlOdbcDsn is the name of data source name
conn2 = odbc::connect("Driver={MySQL ODBC 8.0 UNICODE Driver};Server=127.0.0.1;Database=ecimp_ver3;User=newuser;Password=dolphindb123;Option=3;") 
conn3 = odbc::connect("Driver=SQL Server;Server=localhost;Database=zyb_test;User =sa;Password=DolphinDB123;")  

语法

odbc::close(conn)

详情

关闭一个 ODBC 连接。

参数

conn 由 odbc::connect 创建的连接句柄。

例子

conn1 = odbc::connect("Dsn=mysqlOdbcDsn") 
odbc::close(conn1)

语法

odbc::query(connHandle|connStr, querySql, [t], [batchSize], [transform])

详情

通过 connHandle 或 connStr 查询数据库并返回 DolphinDB 表。

参数

connHandle| connStr 连接句柄或连接字符串。

querySql 表示查询的 SQL 语句。

t 表对象。若指定，查询结果将保存到该表中。请注意，t 的各字段类型必须与 ODBC 返回的结果兼容（见“类型支持”一节），否则将引发异常。

batchSize 从 ODBC 查询到的数据行数到达 batchSize 后，会将当前已经读到的数据追加到表 t 中。默认值为 262,144。

transform 一元函数，且入参必须是一个表。如果指定了 transform 参数，需要先创建分区表，再加载数据。程序会对数据文件中的数据应用 transform 参数指定的函数后，将得到的结果保存到数据库中。

例子

t=odbc::query(conn1,"SELECT max(time),min(time) FROM ecimp_ver3.tbl_monitor;")

语法

odbc::execute(connHandle or connStr, SQLstatements)

详情

执行 SQL 语句。

参数

connHandle| connStr 连接句柄或连接字符串。

SQLstatements SQL 语句。

例子

odbc::execute(conn1,"delete from ecimp_ver3.tbl_monitor where `timestamp` BETWEEN '2013-03-26 00:00:01' AND '2013-03-26 23:59:59'")

语法

odbc::append(connHandle, tableData, tablename, [createTableIfNotExist], [insertIgnore])

详情

将 DolphinDB 表追加到连接的数据库。

参数

connHandle 连接句柄。

tableData DolphinDB 表。

tablename 连接的数据库中表的名称。

createTableIfNotExist 布尔值，表示是否创建一个新表，默认值是 true。

insertIgnore 布尔值，表示在插入时是否忽略重复数据，默认值是 false。

例子

t=table(1..10 as id,take(now(),10) as time,rand(1..100,10) as value)
odbc::append(conn1, t,"ddbtale", true)
odbc::query(conn1,"SELECT * FROM ecimp_ver3.ddbtale")