本文实例讲述了C语言连接并操作Sedna XML数据库的方法。分享给大家供大家参考。具体如下：
|
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
50
51
52
53
54
55
56
57
58
59
60
|
#include "libsedna.h"
#include "stdio.h"
int handle_error(SednaConnection* conn,
const char* op,
int close_connection) {
printf("%s failed: \n%s\n", op, SEgetLastErrorMsg(conn));
if(close_connection == 1) SEclose(conn);
return -1;
}
int main() {
struct SednaConnection conn = SEDNA_CONNECTION_INITIALIZER;
int bytes_read, res, value;
char buf[1024];
/* Turn off autocommit mode */
value = SEDNA_AUTOCOMMIT_OFF;
res = SEsetConnectionAttr(&conn, SEDNA_ATTR_AUTOCOMMIT,
(void*)&value, sizeof(int));
/* Connect to the database */
res = SEconnect(&conn, "localhost", "test_db",
"SYSTEM", "MANAGER");
if(res != SEDNA_SESSION_OPEN)
return handle_error(&conn, "Connection", 0);
/* Begin a new transaction */
res = SEbegin(&conn);
if(res != SEDNA_BEGIN_TRANSACTION_SUCCEEDED)
return handle_error(&conn, "Transaction begin", 1);
/* Load file "region.xml" into the document "region" */
res = SEexecute(&conn, "LOAD 'region.xml' 'region'");
if(res != SEDNA_BULK_LOAD_SUCCEEDED)
return handle_error(&conn, "Bulk load", 1);
/* Execute XQuery statement */
res = SEexecute(&conn, "doc('region')/*/*");
if(res != SEDNA_QUERY_SUCCEEDED)
return handle_error(&conn, "Query", 1);
/* Iterate and print the result sequence */
while((res = SEnext(&conn)) != SEDNA_RESULT_END) {
if (res == SEDNA_ERROR)
return handle_error(&conn, "Getting item", 1);
do {
bytes_read = SEgetData(&conn, buf, sizeof(buf) - 1);
if(bytes_read == SEDNA_ERROR)
return handle_error(&conn, "Getting item", 1);
buf[bytes_read] = '\0';
printf("%s\n", buf);
} while(bytes_read > 0);
}
/* Drop document "region" */
res = SEexecute(&conn, "DROP DOCUMENT 'region'");
if(res != SEDNA_UPDATE_SUCCEEDED)
return handle_error(&conn, "Drop document", 1);
/* Commit transaction */
res = SEcommit(&conn);
if(res != SEDNA_COMMIT_TRANSACTION_SUCCEEDED)
return handle_error(&conn, "Commit", 1);
/* Close connection */
res = SEclose(&conn);
if(res != SEDNA_SESSION_CLOSED)
return handle_error(&conn, "Close", 0);
return 0;
}
|
希望本文所述对大家的C语言程序设计有所帮助。