api在c语言中的使用,Mysql的C语言API接口在项目中的使用

末蓝、 2022-10-14 15:45 183阅读 0赞

\#include "Mysql.h"

int Mysql::select\_user\_store(char \*sql,char \*user\_info)

int reta = mysql\_real\_query1(sql);

if ( 0 != reta)\{

return (-1);

//process result

result = mysql\_store\_result(conn);

if (result == NULL)\{

if (mysql\_error(conn))

fprintf(stderr, "%s\\n", mysql\_error(conn));

else

fprintf(stderr, "%s\\n", "unknown error\\n");

return -1;

row = mysql\_fetch\_row(result);

if (!row)

cout << "the user you selected not exist!" << endl;

return -2;

if (user\_info == NULL)

return 0;

sprintf(user\_info, "%s:%s:%s:%s:%s:%s:%s:%s", row\[0\], row\[1\],row\[2\],row\[3\],row\[4\],row\[5\],row\[6\],row\[7\]);

return (0);

Mysql::Mysql():result(NULL),conn(NULL),row(NULL)

//create connection to MySQL

conn = mysql\_init(NULL);

if (mysql\_real\_connect(conn, "localhost", "root", "123", "soft", 0, NULL, 0) == NULL)\{

fprintf(stderr, "Sorry, no database connection ...\\n");

mysql\_query(conn, "SET NAMES 'utf8'");

Mysql::~Mysql()

//release memory, server connection

if (result)

mysql\_free\_result(result);

mysql\_close(conn);

int Mysql::add\_user(char user\_info\[8\]\[512\])

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"insert into usrs(name,tel,mail,work,creater,create\_time,privilege,passwd) values('%s','%s','%s','%s','%s','%s','%s','%s')",user\_info\[0\],user\_info\[1\],user\_info\[2\],user\_info\[3\],user\_info\[4\],user\_info\[5\],user\_info\[6\],user\_info\[7\]);

return mysql\_real\_query1(sql);

int Mysql::delete\_user(char \*name)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"delete from usrs where name = '%s'",name);

return mysql\_real\_query1(sql);

int Mysql::select\_users\_name(char \*\*p)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"select name from usrs");

int ret = mysql\_real\_query1(sql);

if (ret != 0)

return -1;

result = mysql\_store\_result(conn);

unsigned int num = mysql\_field\_count(conn);

unsigned int count = mysql\_num\_rows(result);

cout << "users name count:" << count << endl;

char \*buffer = new char\[count \* 8\];

bzero(buffer, count \* 8);

while (row = mysql\_fetch\_row(result))

for (unsigned int i = 0; i < num; i++)

strcat(buffer, row\[i\]);

strcat(buffer, ":");

\*p = buffer;

return 0;

int Mysql::select\_user(char\* acnt,char \*user\_info)

if (NULL == acnt)\{ //如果输入acnt为NULL,则返回为-1

return (-1);

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"select \* from usrs where name = '%s'",acnt);

cout << sql << endl;

return select\_user\_store(sql, user\_info);

int Mysql::update\_user(char user\_info\[8\]\[512\])

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"update usrs set name = '%s',tel = '%s',mail='%s',work = '%s',privilege = '%s',passwd = '%s'where name = '%s'",user\_info\[0\],user\_info\[1\],user\_info\[2\],user\_info\[3\],user\_info\[4\],user\_info\[5\], user\_info\[0\]);

printf("update usrs set name = '%s',tel = '%s',mail='%s',work = '%s',creater = '%s',create\_time = '%s',role = '%s',passwd = '%s'\\n",user\_info\[0\],user\_info\[1\],user\_info\[2\],user\_info\[3\],user\_info\[4\],user\_info\[5\],user\_info\[6\],user\_info\[7\]);

return mysql\_real\_query1(sql);

int Mysql::update\_privilege(char \*str)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"update privilege set id1 = '%c',id2='%c',id3 = '%c',id4 = '%c',id5 = '%c',id6 = '%c',id7 = '%c', id8 = '%c', id9 = '%c', id10 = '%c' where name = 'system'",str\[0\],str\[1\],str\[2\],str\[3\],str\[4\],str\[5\],str\[6\],str\[7\], str\[8\], str\[9\]);

if (mysql\_real\_query1(sql))

return -1;

for (int i = 1; i <= 10; i++)

if (str\[i-1\] == '0')

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql, "update privilege set id%d = 0", i);

cout << sql << endl;

if (mysql\_real\_query1(sql))

return -1;

return 0;

int Mysql::select\_privilege(char \*str)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"select \* from privilege where name = 'system'");

if (mysql\_real\_query1(sql))

return -1;

result = mysql\_store\_result(conn);

row = mysql\_fetch\_row(result);

if (row == NULL)

return -1;

unsigned int num = mysql\_field\_count(conn);

for (unsigned int i = 0; i < num-1; i++)

strcat(str, row\[i\]);

return 0;

int Mysql::mysql\_real\_query1(char \*sql)

if (mysql\_query(conn,sql))\{

fprintf(stderr,"%s\\n\\n",mysql\_error(conn));

fprintf(stderr,"%s\\n",sql);

return (-1);

return (0);

int Mysql::add\_role(char \*role,char \*role\_info)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"insert into privilege(id1,id2,id3,id4,id5,id6,id7,id8,id9,id10,name) values('%c','%c','%c','%c','%c','%c','%c','%c','%c','%c','%s')",role\_info\[0\],role\_info\[1\],role\_info\[2\],role\_info\[3\],role\_info\[4\],role\_info\[5\],role\_info\[6\],role\_info\[7\],role\_info\[8\],role\_info\[9\], role);

return mysql\_real\_query1(sql);

int Mysql::delete\_role(char \*role)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"delete from privilege where name= '%s'",role);

return mysql\_real\_query1(sql);

int Mysql::update\_role(char \*role,char \*role\_info)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"update privilege set id1 = '%c',id2 = '%c',id3 = '%c',id4 = '%c',id5 = '%c',id6 = '%c',id7 ='%c',id8 = '%c',id9 = '%c',id10 = '%c' where name = '%s'",role\_info\[0\],role\_info\[1\],role\_info\[2\],role\_info\[3\],role\_info\[4\],role\_info\[5\],role\_info\[6\],role\_info\[7\],role\_info\[8\],role\_info\[9\], role);

return mysql\_real\_query1(sql);

int Mysql::select\_role(char \*role,char \*role\_info)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"select \* from privilege where name = '%s'",role);

return select\_role\_store(sql,role\_info);

int Mysql::select\_role\_store(char \*sql,char \*role\_info)

if ( -1 == mysql\_real\_query1(sql))

return (-1);

//process result

result = mysql\_store\_result(conn);

if (result == NULL)

if (mysql\_error(conn))

fprintf(stderr, "%s\\n", mysql\_error(conn));

fprintf(stderr, "%s\\n", "unknown error\\n");

return -1;

if (row = mysql\_fetch\_row(result))

if (NULL == role\_info)

return (0);

\}else \{

sprintf(role\_info,"%s%s%s%s%s%s%s%s%s%s%s:%s",row\[0\],row\[1\],row\[2\],row\[3\],row\[4\],row\[5\],row\[6\],row\[7\],row\[8\],row\[9\],row\[10\]);

return 0;

else

return -2;

return (0);

int Mysql::select\_roles\_name(char \*\*p)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"select name from privilege");

int ret = mysql\_real\_query1(sql);

if (ret != 0)

return -1;

result = mysql\_store\_result(conn);

unsigned int num = mysql\_field\_count(conn);

unsigned int count = mysql\_num\_rows(result);

cout << "roles name count:" << count << endl;

char \*buffer = new char\[count \* 8\];

bzero(buffer, count \* 8);

while (row = mysql\_fetch\_row(result))

for (unsigned int i = 0; i < num; i++)

strcat(buffer, row\[i\]);

strcat(buffer, ":");

\*p = buffer;

return 0;

int Mysql::selectUserPrivilege(const char \*name, char \*body)

char sql\[MAX\_SQL\_LEN\];

bzero(sql,MAX\_SQL\_LEN);

sprintf(sql,"select privilege.id1, privilege.id2, privilege.id3, privilege.id4, privilege.id5, privilege.id6, privilege.id7, privilege.id8, privilege.id9, privilege.id10, usrs.name from usrs, privilege where usrs.name = '%s' and usrs.privilege = privilege.name", name);

cout << sql << endl;

int ret = mysql\_real\_query1(sql);

if (ret != 0)

return -1;

result = mysql\_store\_result(conn);

if (row = mysql\_fetch\_row(result))

for (int i = 0; i < 11; i++)

strcat(body, row\[i\]);

cout << body << endl;

return 0;

else

return -2;