-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathsqlconn.cpp
More file actions
100 lines (93 loc) · 1.94 KB
/
Copy pathsqlconn.cpp
File metadata and controls
100 lines (93 loc) · 1.94 KB
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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
#include "sqlconn.h"
#include <QDebug>
#include <stdlib.h>
#include <mysql/mysql_com.h>
#include "hcdef.h"
#include "json.h"
#include <QJsonDocument>
#include <QJsonObject>
SqlConn::SqlConn(QObject *parent) : QObject(parent)
{
sql = mysql_init(NULL);
if(sql==NULL){
qDebug() << "mysql init error!";
exit(1);
}
sql = mysql_real_connect(sql,HC_ADDRESS,HC_USER,HC_PASSWD,HC_DB,0,NULL,0);
if(sql==NULL){
qDebug() << "mysql mysql_real_connect error!";
exit(1);
}
}
SqlConn *SqlConn::getInstance()
{
static SqlConn* sqlConn = NULL;
if(sqlConn==NULL)
{
sqlConn = new SqlConn;
}
return sqlConn;
}
int SqlConn::insert(QString str)
{
int status = mysql_query(sql,str.toUtf8().data());
if(status!=0)
{
qDebug() << "mysql query error!";
return -1;
}
return 0;
}
SqlConn::~SqlConn()
{
if(sql!=NULL)
{
mysql_close(sql);
sql = NULL;
}
}
int SqlConn::selData(QString str,QByteArray* array)
{
int status = mysql_query(sql,str.toUtf8().data());
if(status!=0)
{
qDebug() << "mysql query error!";
return -1;
}
int count = mysql_field_count(sql);
MYSQL_RES * result = mysql_store_result(sql);
if(result==NULL)
{
qDebug() << "mysql store result error!";
return -1;
}
int i;
MYSQL_ROW row ;
MYSQL_FIELD *field;
QString name;
int k = 0;
field = mysql_fetch_field(result);
while((row= mysql_fetch_row(result)))
{
Json j;
for(i = 0;i<count;++i)
{
name.append(field[i].name);
j.insert(name,row[i]);
name.clear();
}
array[k++] = j.toJson();
}
mysql_free_result(result);
return 0;
}
int SqlConn::update(QString str)
{
int status = mysql_query(sql,str.toUtf8().data());
if(status!=0)
{
qDebug() << "mysql query error!";
return -1;
}
return 0;
}