xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[modify]

This commit is contained in:
Hui Li 2020-06-04 18:36:10 +08:00
parent 36d91237db
commit f7a1827341
2 changed files with 28 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/client/src/tscPrepare.c
View File

@ -614,11 +614,8 @@ int taos_stmt_execute(TAOS_STMT* stmt) {
tfree(pStmt->pSql->sqlstr); tfree(pStmt->pSql->sqlstr);
pStmt->pSql->sqlstr = sql; pStmt->pSql->sqlstr = sql;
SSqlObj* pSql = taos_query((TAOS*)pStmt->taos, pStmt->pSql->sqlstr); SSqlObj* pSql = taos_query((TAOS*)pStmt->taos, pStmt->pSql->sqlstr);
if (pSql != NULL) { ret = taos_errno(pSql);
ret = pSql->res.code; taos_free_result(pSql);
} else {
ret = terrno;
}
} }
} }
return ret; return ret;

41
tests/examples/c/prepare.c
View File

@ -5,6 +5,7 @@
#include <stdlib.h> #include <stdlib.h>
#include <string.h> #include <string.h>
// # #include "taos.h" // TAOS header file
#include "taos.h" #include "taos.h"
@ -14,38 +15,49 @@ int main(int argc, char *argv[])
{ {
TAOS *taos; TAOS *taos;
TAOS_RES *result; TAOS_RES *result;
int code;
TAOS_STMT *stmt; TAOS_STMT *stmt;
// connect to server // connect to server
if (argc < 2) { //if (argc < 2) {
printf("please input server ip \n"); // printf("please input server ip \n");
return 0; // return 0;
} //}
// init TAOS // init TAOS
taos_init(); taos_init();
taos = taos_connect(argv[1], "root", "taosdata", NULL, 0); taos = taos_connect("127.0.0.1", "root", "taosdata", NULL, 0);
if (taos == NULL) { if (taos == NULL) {
printf("failed to connect to db, reason:%s\n", taos_errstr(taos)); printf("failed to connect to db, reason:%s\n", taos_errstr(taos));
exit(1); exit(1);
} }
taos_query(taos, "drop database demo"); result = taos_query(taos, "drop database demo");
if (taos_query(taos, "create database demo") != 0) { taos_free_result(result);
printf("failed to create database, reason:%s\n", taos_errstr(taos));
result = taos_query(taos, "create database demo");
code = taos_errno(result);
if (code != 0) {
printf("failed to create database, reason:%s\n", taos_errstr(result));
taos_free_result(result);
exit(1); exit(1);
} }
taos_free_result(result);
taos_query(taos, "use demo"); result = taos_query(taos, "use demo");
taos_free_result(result);
// create table // create table
const char* sql = "create table m1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin binary(40), blob nchar(10))"; const char* sql = "create table m1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin binary(40), blob nchar(10))";
if (taos_query(taos, sql) != 0) { result = taos_query(taos, sql);
printf("failed to create table, reason:%s\n", taos_errstr(taos)); code = taos_errno(result);
if (code != 0) {
printf("failed to create table, reason:%s\n", taos_errstr(result));
taos_free_result(result);
exit(1); exit(1);
} }
taos_free_result(result);
// sleep for one second to make sure table is created on data node // sleep for one second to make sure table is created on data node
// taosMsleep(1000); // taosMsleep(1000);
@ -130,7 +142,7 @@ int main(int argc, char *argv[])
int is_null = 1; int is_null = 1;
sql = "insert into m1 values(?,?,?,?,?,?,?,?,?,?)"; sql = "insert into m1 values(?,?,?,?,?,?,?,?,?,?)";
int code = taos_stmt_prepare(stmt, sql, 0); code = taos_stmt_prepare(stmt, sql, 0);
if (code != 0){ if (code != 0){
printf("failed to execute taos_stmt_prepare. code:0x%x\n", code); printf("failed to execute taos_stmt_prepare. code:0x%x\n", code);
} }
@ -159,7 +171,6 @@ int main(int argc, char *argv[])
exit(1); exit(1);
} }
taos_stmt_close(stmt); taos_stmt_close(stmt);
printf("==== success inset data ====.\n");
// query the records // query the records
stmt = taos_stmt_init(taos); stmt = taos_stmt_init(taos);