C++ Poco ODBC 事务 - 自动提交模式
C++ Poco ODBC Transactions - AutoCommit mode
我目前正在尝试在我的 C++ 应用程序中使用事务,但我遇到了 ODBC 的自动提交模式问题。
我正在使用 POCO 库在同一台机器上创建到 PostgreSQL 数据库的连接。目前,我可以将数据作为单个语句发送到这个数据库,但我不知道如何使用 Poco 的事务库来更快地发送这些数据。
因为我有几千条记录要插入,所以继续使用单个插入语句非常缓慢且不切实际 - 所以我尝试使用 Poco 的事务来加快速度(相当快)。
我遇到的错误理论上很简单 - Poco 抛出以下错误:
'Invalid access: Session is in auto commit mode.'
我明白,因此,我应该以某种方式将 "auto commit" 设置为 false - 因为它只允许我逐行向数据库提交数据,而不是作为单个事务。
问题是我怎么设置的。
目前,我有一个从 Session.h 创建的 session,看起来很像这样:
session = new Poco::Data::Session(
"ODBC",
connection_data.str()
);
其中连接数据是一个简单的字符串流,包含登录信息、密码、数据库、服务器和 "Driver={PostgreSQL ANSI};" 以告诉 ODBC 使用 PostgreSQL 的 driver。
我试过通过 session 的 setFeature 或 setProperty 设置将 属性 "autocommit" 设置为 false,这当然没有用。 (此时更像是一次沟渠尝试)。
session->setFeature("AUTOCOMMIT", false);
环顾四周,我看到了一种可能的替代方法,即直接从 ODBC/session/SessionImpl.h 创建一个 ODBC sessionImpl 而不是使用上面的这种通用方法,然后创建一个新的 session object 从此.
这样做的好处是 ODBC 的 sessionImpl 在 header 中引用了自动提交模式,这表明它能够处理这个问题:
void autoCommit(const std::string&, bool val);
/// Sets autocommit property for the session.
但是,之前没有使用过 sessionImpl,我不能保证这是否可行,或者是否可以使用有限的可用文档来实现它。
我使用的是 C++ 03(不是 11),Visual Studio 2015
Poco 1.7.5
提升(需要时)
Would any one know the correct way of setting this feature (above) or a alternative method to achieving this?
编辑:查看 poco 的源代码,位于:
https://github.com/pocoproject/poco/blob/develop/Data/ODBC/src/SessionImpl.cpp#L153
这个属性好像叫autoCommit
,正在看
https://github.com/pocoproject/poco/blob/develop/Data/include/Poco/Data/AbstractSessionImpl.h#L120
属性 名称的大小写似乎很重要。那么,如果您使用 session->setFeature("autoCommit", false);
有帮助吗?
你不能只在相应的 Session 对象上调用 session->begin();
和 session->end();
吗?
session->canTransact()
返回了什么?
根据文档 begin()
将开始一个新事务,文档没有提到需要在之前或之后设置的任何 属性。
我目前正在尝试在我的 C++ 应用程序中使用事务,但我遇到了 ODBC 的自动提交模式问题。
我正在使用 POCO 库在同一台机器上创建到 PostgreSQL 数据库的连接。目前,我可以将数据作为单个语句发送到这个数据库,但我不知道如何使用 Poco 的事务库来更快地发送这些数据。
因为我有几千条记录要插入,所以继续使用单个插入语句非常缓慢且不切实际 - 所以我尝试使用 Poco 的事务来加快速度(相当快)。
我遇到的错误理论上很简单 - Poco 抛出以下错误:
'Invalid access: Session is in auto commit mode.'
我明白,因此,我应该以某种方式将 "auto commit" 设置为 false - 因为它只允许我逐行向数据库提交数据,而不是作为单个事务。
问题是我怎么设置的。
目前,我有一个从 Session.h 创建的 session,看起来很像这样:
session = new Poco::Data::Session(
"ODBC",
connection_data.str()
);
其中连接数据是一个简单的字符串流,包含登录信息、密码、数据库、服务器和 "Driver={PostgreSQL ANSI};" 以告诉 ODBC 使用 PostgreSQL 的 driver。
我试过通过 session 的 setFeature 或 setProperty 设置将 属性 "autocommit" 设置为 false,这当然没有用。 (此时更像是一次沟渠尝试)。
session->setFeature("AUTOCOMMIT", false);
环顾四周,我看到了一种可能的替代方法,即直接从 ODBC/session/SessionImpl.h 创建一个 ODBC sessionImpl 而不是使用上面的这种通用方法,然后创建一个新的 session object 从此.
这样做的好处是 ODBC 的 sessionImpl 在 header 中引用了自动提交模式,这表明它能够处理这个问题:
void autoCommit(const std::string&, bool val);
/// Sets autocommit property for the session.
但是,之前没有使用过 sessionImpl,我不能保证这是否可行,或者是否可以使用有限的可用文档来实现它。
我使用的是 C++ 03(不是 11),Visual Studio 2015 Poco 1.7.5 提升(需要时)
Would any one know the correct way of setting this feature (above) or a alternative method to achieving this?
编辑:查看 poco 的源代码,位于:
https://github.com/pocoproject/poco/blob/develop/Data/ODBC/src/SessionImpl.cpp#L153
这个属性好像叫autoCommit
,正在看
https://github.com/pocoproject/poco/blob/develop/Data/include/Poco/Data/AbstractSessionImpl.h#L120
属性 名称的大小写似乎很重要。那么,如果您使用 session->setFeature("autoCommit", false);
有帮助吗?
你不能只在相应的 Session 对象上调用 session->begin();
和 session->end();
吗?
session->canTransact()
返回了什么?
根据文档 begin()
将开始一个新事务,文档没有提到需要在之前或之后设置的任何 属性。