|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
#include "CondTools/RPC/interface/RPCDBCom.h"
#include "RelationalAccess/IRelationalDomain.h"
#include "RelationalAccess/IConnection.h"
#include "RelationalAccess/ISession.h"
#include "RelationalAccess/RelationalServiceException.h"
#include "CoralKernel/Context.h"
RPCDBCom::RPCDBCom() : m_connection(nullptr) {
coral::Context& context = coral::Context::instance();
context.loadComponent("CORAL/RelationalPlugins/oracle");
coral::IHandle<coral::IRelationalDomain> domain =
context.query<coral::IRelationalDomain>("CORAL/RelationalPlugins/oracle");
if (!domain.isValid())
throw std::runtime_error("Could not load the OracleAccess plugin");
}
RPCDBCom::~RPCDBCom() {
if (m_connection)
delete m_connection;
}
coral::ISession* RPCDBCom::connect(const std::string& connectionString,
const std::string& userName,
const std::string& password) {
coral::Context& ctx = coral::Context::instance();
ctx.loadComponent("CORAL/RelationalPlugins/oracle");
coral::IHandle<coral::IRelationalDomain> iHandle =
ctx.query<coral::IRelationalDomain>("CORAL/RelationalPlugins/oracle");
if (!iHandle.isValid()) {
throw std::runtime_error("Could not load the OracleAccess plugin");
}
std::pair<std::string, std::string> connectionAndSchema = iHandle->decodeUserConnectionString(connectionString);
if (!m_connection)
m_connection = iHandle->newConnection(connectionAndSchema.first);
if (!m_connection->isConnected())
m_connection->connect();
coral::ISession* session = m_connection->newSession(connectionAndSchema.second);
if (session) {
session->startUserSession(userName, password);
}
//memory leaking
return session;
}
void RPCDBCom::setVerbosityLevel(coral::MsgLevel level) { coral::MessageStream::setMsgVerbosity(level); }
|