C++ OCCI API数据库操作之连接、返回查询结果集为json格式

 1 #include <iostream>
 2 #include <occi.h>
 3 #include <json.h>
 4 #pragma comment(lib,"oraocci12.lib")
 5 #pragma comment(lib,"json_vc71_libmt.lib")
 6 using namespace std;
 7 using namespace oracle::occi;
 8 
 9 int main()
10 {
11 　　//初始化occi对象
12 　　Environment *env = NULL;
13 　　Connection *conn = NULL;
14 　　Statement *stmt = NULL;
15 　　ResultSet *res = NULL;
16     
17 　　try
18 　　{
19 　　　　char usrName[] = "shaqima";
20 　　　　char usrPwd[] = "userpwd";
21 　　　　char connectStr[] = "10.10.82.25:1521/orcl";
22 　　　　//创建连接环境
23 　　　　env = Environment::createEnvironment();
24 　　　　//连接到数据库
25 　　　　conn = env->createEnvironment(usrName,usrPwd,connectStr);
26 　　　　if(!conn)
27 　　　　{
28 　　　　　　cout <<"error: connect failed!"<<endl;
29 　　　　　　return 0;
30 　　　　}
31 
32 　　　　//oracle sql语句
33 　　　　char sqlStr[] = "select * from DEVICE_INFO t where t.ID=:1";
34 　　　　stmt = conn->createStatement(sqlStr);
35 　　　　//设置sql变量
36 　　　　stmt->setString(1,"1");
37 　　　　//执行sql
38 　　　　res = stmt->executeQuery();
39 
40 　　　　//初始化jsoncpp对象
41 　　　　Json::Reader reader;
42 　　　　//根节点
43 　　　　Json::Value rootNode;
44 　　　　//子节点
45 　　　　Json::Value childNode;
46 
47 　　　　int nodeNum = 0;
48 　　　　//查询出结果集，并存入json节点
49 　　　  while(res->next())
50 　　　　{
51 　　　　　　childNode["Id"] = res->getInt(1);
52 　　　　　　childNode["AssetCode"] = res->getString(2);
53 　　　　　　childNode["EncryptDrive"] = res->getString(3);
54 　　　　　　//将子节点挂载到根节点
55 　　　　　　rootNode[nodeNum] = Json::Value(childNode);
56 　　　　　　nodeNum++;
57 　　　　}
58 
59 　　　　cout<<"使用.toStyledString()转换为标准json格式："<<endl;
60 　　　　cout<<rootNode.toStyledString()<<endl;
61 
62 　　　　Json::FastWriter fw;
63 　　　　cout<<"转换成易于传输的josn字符串格式"<<endl;
64 　　　　cout<<fw.write(rootNode)<<endl;
65 　　}    
66 　  catch(SQLException ex)
67 　　{
68 　　　　cout<<"ErrorCode:"<<ex.getErrorCode()<<endl;
69 　　　　cout<<"ErrorMsg:"<<ex.getMessage()<<endl;
70 　　}  
71 　　//释放资源
72 　　stmt->closeResultSet(res);
73 　　conn->terminateStatement(stmt);
74 　　env->terminateConnection(conn);
75 　　Environment::terminateEnvironment(env);
76 
77 　　system("pause");
78 　　return 1;
79 }