我目前正试图在C++应用程序中使用事务,但ODBC的自动提交模式有问题。
我使用POCO库在同一台机器上创建到PostgreSQL数据库的连接。目前,我可以将数据作为单个语句发送到该数据库,但我无法理解如何使用Poco的事务库来更快地发送这些数据。
因为我有几千条记录要插入,所以继续使用单插入语句是非常缓慢和不切实际的——所以我试图使用Poco的事务来加快速度(相当大的一点)。
我遇到的错误理论上很简单-Poco抛出了以下错误:
'Invalid access: Session is in auto commit mode.'
我知道,因此,我应该以某种方式将"自动提交"设置为false,因为它只允许我逐行将数据提交到数据库,而不是作为单个事务。
问题是我是如何设置的。
目前,我有一个从session.h创建的会话,看起来很像这样:
session = new Poco::Data::Session(
"ODBC",
connection_data.str()
);
其中连接数据是一个简单的字符串流,包含登录信息、密码、数据库、服务器和"Driver={PostgreSQL ANSI};",以告诉ODBC使用PostgreSQL的驱动程序。
我尝试过通过会话的setFeature或setProperty设置将属性"autocommit"设置为false,当然,这没有用。(在这一点上,这更像是一次试探)。
session->setFeature("AUTOCOMMIT", false);
环顾四周,我看到了一种可能的替代方法,即直接从ODBC/session/sessionImpl.h创建ODBC sessionImpl,而不是使用上面的通用方法,然后从中创建一个新的会话对象。
这样做的好处是ODBC的sessionImpl在标头中引用了自动提交模式,这表明它能够处理以下问题:
void autoCommit(const std::string&, bool val);
/// Sets autocommit property for the session.
然而,由于以前没有使用过sessionImpl,我无法确定这是否可行,或者在有限的可用文档中是否可以实现。
我正在使用Visual Studio 2015中的C++03(非11)Poco 1.7.5增强(如需要)
有人知道设置此功能的正确方法(如上)或实现此功能的替代方法吗?
edit:查看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()
将开始新的交易,单据没有提到任何需要在之前或之后设置的属性。
请参阅:https://pocoproject.org/docs/Poco.Data.Session.html
也面临类似的问题。首先在开始之前()需要:
m_ses.setFeature("autoCommit", false);
m_ses.begin();
第二个问题是,这个特性保持";自动提交";对于所有其他会话,为false。所以不要忘记在下一次会议上打电话给
session.setFeature("autoCommit", true);