1 /* create table T1 with 10 fields.
2 * insert some records into it.
3 * delete records from T1 with where clause
11 AbsSqlConnection
*con
= createConnection();
12 rv
= con
->connect("root","manager");
15 AbsSqlStatement
*stmt
= createStatement();
16 stmt
->setConnection(con
);
21 if(strcmp(getenv("DSN"),"oracle")==0){
22 strcpy(statement
,"INSERT INTO t1 VALUES(?,?,?,?,?,?,?,?,?);");
24 else if(strcmp(getenv("DSN"),"db2")==0){
25 strcpy(statement
,"INSERT INTO t1 VALUES(?,?,?,?,?,?,?,?,?,?)");
28 strcpy(statement
,"INSERT INTO t1 VALUES(?,?,?,?,?,?,?,?,?,?);");
33 char f3var
[35]="jitendra";
37 f6var
.set(2007,01,21);
43 f8var
.setDate(2007,01,21);
44 f8var
.setTime(12,29,30);
47 long long f10var
= 12000;
49 rv
= stmt
->prepare(statement
);
56 if(strcmp(getenv("DSN"),"psql")==0){
65 rv
= con
->beginTrans();
68 stmt
->setIntParam(1,f1var
);
69 stmt
->setShortParam(2,f2var
);
70 stmt
->setStringParam(3,f3var
);
71 stmt
->setFloatParam(4,f4var
);
72 stmt
->setFloatParam(5,f5var
);
73 stmt
->setDateParam(6,f6var
);
74 if(strcmp(getenv("DSN"),"oracle")==0){
75 stmt
->setTimeStampParam(7,f8var
);
76 stmt
->setIntParam(8,f9var
);
77 stmt
->setLongLongParam(9,f10var
);
79 stmt
->setTimeParam(7,f7var
);
80 stmt
->setTimeStampParam(8,f8var
);
81 stmt
->setIntParam(9,f9var
);
82 stmt
->setLongLongParam(10,f10var
);
85 rv
= stmt
->execute(rows
);
91 printf("Total rows inserted %d\n",count
);
95 //*********************************************************
97 // delete records from the T1
98 if(strcmp(getenv("DSN"),"oracle")==0)
99 strcpy(statement
,"DELETE FROM t1 WHERE f10=? AND f9=? AND f8=? AND f6=? AND f5=? AND f4=? AND f3=? AND f2=? AND f1=?;");
100 else if(strcmp(getenv("DSN"),"db2")==0)
101 strcpy(statement
,"DELETE FROM t1 WHERE f10=? AND f9=? AND f8=? AND f7=? AND f6=? AND f5=? AND f4=? AND f3=? AND f2=? AND f1=?");
103 strcpy(statement
,"DELETE FROM t1 WHERE f10=? AND f9=? AND f8=? AND f7=? AND f6=? AND f5=? AND f4=? AND f3=? AND f2=? AND f1=?;");
105 rv
= stmt
->prepare(statement
);
106 if(rv
!=OK
){delete stmt
;delete con
;return -1;}
107 if(strcmp(getenv("DSN"),"psql")==0){
112 /* stmt->bindField(1,&f10var);
113 stmt->bindField(2,&f9var);
114 stmt->bindField(3,&f8var);
115 stmt->bindField(4,&f7var);
116 stmt->bindField(5,&f6var);
117 stmt->bindField(6,&f5var);
118 stmt->bindField(7,&f4var);
119 stmt->bindField(8,f3var);
120 stmt->bindField(9,&f2var);
121 stmt->bindField(10,&f1var);*/
124 char f3var1
[20] ="jitendra";
126 float f5var1
= 10.50;
128 f6var1
.set(2007,1,21);
131 f7var1
.set(12,29,30);
134 f8var1
.setDate(2007,1,21);
135 f8var1
.setTime(12,29,30);
138 long long f10var1
=12000;
141 for(int i
=5;i
<10;i
++)
143 rv
= con
->beginTrans();
146 stmt
->setLongLongParam(1,f10var1
);
147 stmt
->setIntParam(2,f9var1
);
148 stmt
->setTimeStampParam(3,f8var1
);
149 if(strcmp(getenv("DSN"),"oracle")==0){
150 stmt
->setDateParam(4,f6var1
);
151 stmt
->setFloatParam(5,f5var1
);
152 stmt
->setFloatParam(6,f4var1
);
153 stmt
->setStringParam(7,f3var1
);
154 stmt
->setShortParam(8,f2var1
);
155 stmt
->setIntParam(9,i
);
157 stmt
->setTimeParam(4,f7var1
);
158 stmt
->setDateParam(5,f6var1
);
159 stmt
->setFloatParam(6,f5var1
);
160 stmt
->setFloatParam(7,f4var1
);
161 stmt
->setStringParam(8,f3var1
);
162 stmt
->setShortParam(9,f2var1
);
163 stmt
->setIntParam(10,i
);
167 rv
= stmt
->execute(rows
);
174 printf("Total row deleted=%d\n",count
);
179 //**********************************************************
182 strcpy(statement
,"SELECT * FROM t1;");
183 if(strcmp(getenv("DSN"),"db2")==0){
184 strcpy(statement
,"SELECT * FROM t1");
186 rv
= stmt
->prepare(statement
);
194 stmt
->bindField(1,&f1var
);
195 stmt
->bindField(2,&f2var
);
196 stmt
->bindField(3,f3var
);
197 stmt
->bindField(4,&f4var
);
198 stmt
->bindField(5,&f5var
);
199 stmt
->bindField(6,&f6var
);
200 if(strcmp(getenv("DSN"),"oracle")==0){
201 stmt
->bindField(7,&f8var
);
202 stmt
->bindField(8,&f9var
);
203 stmt
->bindField(9,&f10var
);
206 stmt
->bindField(7,&f7var
);
207 stmt
->bindField(8,&f8var
);
208 stmt
->bindField(9,&f9var
);
209 stmt
->bindField(10,&f10var
);
212 rv
= con
->beginTrans();
215 while(stmt
->fetch() !=NULL
)
217 if(strcmp(getenv("DSN"),"oracle")==0)
218 printf("F1=%d | F2=%hd | F3=%s | F4=%f | F5=%f | DATE=%d-%d-%d | TIMESTAMP=%d-%d-%d %d:%d:%d | F9=%d | F10=%lld \n",f1var
,f2var
,f3var
,f4var
,f5var
,f6var
.year(),f6var
.month(),f6var
.dayOfMonth(),f8var
.year(),f8var
.month(),f8var
.dayOfMonth(),f8var
.hours(),f8var
.minutes(),f8var
.seconds(),f9var
,f10var
);
220 printf("F1=%d | F2=%hd | F3=%s | F4=%f | F5=%f | DATE=%d-%d-%d | TIME=%d:%d:%d | TIMESTAMP=%d-%d-%d %d:%d:%d | F9=%d | F10=%lld \n",f1var
,f2var
,f3var
,f4var
,f5var
,f6var
.year(),f6var
.month(),f6var
.dayOfMonth(),f7var
.hours(),f7var
.minutes(),f7var
.seconds(),f8var
.year(),f8var
.month(),f8var
.dayOfMonth(),f8var
.hours(),f8var
.minutes(),f8var
.seconds(),f9var
,f10var
);
234 printf("Total row fetched=%d\n",count
);