generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-04-01 01:16:55 +02:00
Code Issues Projects Releases Wiki Activity

add fail-readonly connection string parameter

Browse Source
This commit is contained in:
Günter Obiltschnig 2020-02-08 15:41:43 +01:00
parent 8bf5fceaaf
commit 506049e360
2 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
Data/MySQL/include/Poco/Data/MySQL/SessionImpl.h
View File

@ -47,7 +47,7 @@ public:
/// Connection string format: /// Connection string format:
/// <str> == <assignment> | <assignment> ';' <str> /// <str> == <assignment> | <assignment> ';' <str>
/// <assignment> == <name> '=' <value> /// <assignment> == <name> '=' <value>
/// <name> == 'host' | 'port' | 'user' | 'password' | 'db' | 'compress' | 'auto-reconnect' | 'reset' /// <name> == 'host' | 'port' | 'user' | 'password' | 'db' | 'compress' | 'auto-reconnect' | 'reset' | 'fail-readonly'
/// <value> == [~;]* /// <value> == [~;]*
/// ///
/// The following settings are supported: /// The following settings are supported:
@ -61,6 +61,9 @@ public:
/// - character-set: connection character set (default: utf8) /// - character-set: connection character set (default: utf8)
/// - reset: reset connection when returned to SessionPool by calling /// - reset: reset connection when returned to SessionPool by calling
/// mysql_reset_connection(). /// mysql_reset_connection().
/// - fail-readonly: if set to true, the session will fail
/// if the database becomes read-only. This corresponds to
/// setFailIfInnoReadOnly(true).
/// ///
/// Warning: Due to a bug in MySQL, resetting the connection with mysql_reset_connection() /// Warning: Due to a bug in MySQL, resetting the connection with mysql_reset_connection()
/// could change the character encoding used for the connection. Therefore the /// could change the character encoding used for the connection. Therefore the

8
Data/MySQL/src/SessionImpl.cpp
View File

@ -92,6 +92,7 @@ void SessionImpl::open(const std::string& connect)
options["secure-auth"] = ""; options["secure-auth"] = "";
options["character-set"] = "utf8"; options["character-set"] = "utf8";
options["reset"] = ""; options["reset"] = "";
options["fail-readonly"] = "";
const std::string& connString = connectionString(); const std::string& connString = connectionString();
for (std::string::const_iterator start = connString.begin();;) for (std::string::const_iterator start = connString.begin();;)
@ -153,6 +154,13 @@ void SessionImpl::open(const std::string& connect)
else if (!options["reset"].empty()) else if (!options["reset"].empty())
throw MySQLException("create session: specify correct reset option (true or false)"); throw MySQLException("create session: specify correct reset option (true or false)");
if (options["fail-readonly"] == "true")
_failIfInnoReadOnly = true;
else if (options["fail-readonly"] == "false")
_failIfInnoReadOnly = false;
else if (!options["fail-readonly"].empty())
throw MySQLException("create session: specify correct fail-readonly option (true or false)");
// Real connect // Real connect
_handle.connect(options["host"].c_str(), _handle.connect(options["host"].c_str(),
options["user"].c_str(), options["user"].c_str(),