comparison Framework/PostgreSQL/PostgreSQLParameters.cpp @ 370:d2b5d9c92214 pg-transactions

PG: test feature: configurable transaction isolation level
author Alain Mazy <am@osimis.io>
date Wed, 22 Feb 2023 16:52:04 +0100
parents 16aac0287485
children 15bfd9a76f8d
comparison
equal deleted inserted replaced
369:557bc5ba3a5c 370:d2b5d9c92214
40 uri_.clear(); 40 uri_.clear();
41 ssl_ = false; 41 ssl_ = false;
42 lock_ = true; 42 lock_ = true;
43 maxConnectionRetries_ = 10; 43 maxConnectionRetries_ = 10;
44 connectionRetryInterval_ = 5; 44 connectionRetryInterval_ = 5;
45 readWriteTransactionStatement_ = "SET TRANSACTION ISOLATION LEVEL SERIALIZABLE READ WRITE";
46 readOnlyTransactionStatement_ = "SET TRANSACTION ISOLATION LEVEL SERIALIZABLE READ ONLY";
45 } 47 }
46 48
47 49
48 PostgreSQLParameters::PostgreSQLParameters() 50 PostgreSQLParameters::PostgreSQLParameters()
49 { 51 {
94 96
95 lock_ = configuration.GetBooleanValue("Lock", true); // Use locking by default 97 lock_ = configuration.GetBooleanValue("Lock", true); // Use locking by default
96 98
97 maxConnectionRetries_ = configuration.GetUnsignedIntegerValue("MaximumConnectionRetries", 10); 99 maxConnectionRetries_ = configuration.GetUnsignedIntegerValue("MaximumConnectionRetries", 10);
98 connectionRetryInterval_ = configuration.GetUnsignedIntegerValue("ConnectionRetryInterval", 5); 100 connectionRetryInterval_ = configuration.GetUnsignedIntegerValue("ConnectionRetryInterval", 5);
101
102 if (configuration.LookupStringValue(s, "ReadWriteTransactionStatement"))
103 {
104 SetReadWriteTransactionStatement(s);
105 }
106
107 if (configuration.LookupStringValue(s, "ReadOnlyTransactionStatement"))
108 {
109 SetReadOnlyTransactionStatement(s);
110 }
111
99 } 112 }
100 113
101 114
102 void PostgreSQLParameters::SetConnectionUri(const std::string& uri) 115 void PostgreSQLParameters::SetConnectionUri(const std::string& uri)
103 { 116 {