Linux에서 Mysql 데이터베이스의 C++ 작업을 구현하는 방법에 대한 자세한 소개
- 黄舟원래의
- 2017-05-31 10:58:313820검색
일 때문에 일주일 동안 다양한 데이터베이스에 액세스하는 C/C++ 방법을 공부하고 데이터베이스 작업 클래스 집합을 캡슐화할 계획입니다. 이제 가장 간단한 부분인 MySQL 데이터베이스에 액세스하는 방법을 소개하겠습니다. 리눅스 .
C++로 프로젝트를 작성하려면 데이터베이스가 필수이기 때문에 지난 이틀 동안 C++로 MySQL 데이터베이스를 조작하는 방법을 배웠습니다. 튜토리얼은 없고, 제가 온라인에서 검색한 지식만 요약해 놓았습니다.MySQL을 사용하여 자체 C APIfunction입니다. 데이터베이스에 연결하려면. 저는 Linux 플랫폼에서 개발하기 때문에 두 번째 방법을 사용합니다. API 함수는 많지만 일반적으로 사용되는 함수는 몇 가지 뿐이고 그 중 몇 가지만 사용합니다.
API 함수1.mysql_real_connect()mysql 서버 연결MYSQL *mysql_real_connect (MYSQL *mysql, const char *host, const char *user, const char *passwd, const char *db, unsigned int port, const char *unix_socket, unsigned long client_flag)연결에 성공하면 MYSQL* 연결 핸들을 반환합니다. 연결에 실패하면
NULL을 반환합니다. 성공적인 연결의 경우 반환 값은 첫 번째 매개 변수
2.mysql_query()
"NULL로 끝나는string"을 지정하는 SQLquery
을 실행하고 결과 테이블을 반환합니다. 쿼리가 성공했다고 가정하면 mysql_num_rows()를 호출하여 SELECT 문에 따라 반환된 행 수를 확인하거나 mysql_affected_rows()를 호출하여 에 해당하는 영향을 받은 행 수를 확인할 수 있습니다. DELETE, INSERT, REPLACE 또는 UPDATE 문.
3.mysql_store_result()
MYSQL_RES *mysql_store_result(MYSQL *mysql)
클라이언트에 설정된 전체 결과를 검색합니다. 클라이언트가 결과 세트를 처리하는 가장 일반적인 방법은 전체 결과 세트를 한 번에 검색하는 mysql_store_result()를 호출하는 것입니다. 이 함수는 서버에서 쿼리에 의해 반환된 모든 행을 가져와 클라이언트에 저장합니다. 데이터를 성공적으로 검색하는 모든 쿼리(SELECT, SHOW, DESCRIBE, EXPLAIN, CHECK TABLE 등)에 대해 mysql_store_result() 또는 mysql_use_result()를 호출해야 합니다. 다른 쿼리의 경우에는 mysql_store_result()나 mysql_use_result()를 호출할 필요가 없지만, 어떠한 경우에도 mysql_store_result()를 호출하면 아무런 해를 끼치거나 성능 저하가 발생하지 않습니다.
4.mysql_num_rows()
결과 집합의 행 수를 반환합니다.
5.mysql_num_fields()
결과 세트의 필드 수를 반환하거나, 실패하면 false를 반환합니다.
MYSQL_FIELD* mysql_fetch_field(MYSQL_RES *result)
다음 테이블 필드의 유형을 가져오고 마지막에 NULL을 반환합니다.
7.mysql_fetch_row()
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
결과 집합에서 다음 행을 가져오고 0보다 큰 값을 가진 array를 성공적으로 반환합니다.
8.mysql_fetch_field_direct()
MYSQL_FIELD* mysql_fetch_field_direct(MYSQL_RES *result, int i);
필드 번호가 주어지면 테이블 필드의 유형을 반환하고 마지막에 NULL을 반환합니다.
간단한 학생 정보 관리 코드
만 보면 기억이 안나서 이 기능을 이용해 학생 정보 관리 인터페이스를 작성했는데, 아아, 작년 이맘때쯤이면 C 언어 강좌 디자인을 하게 됐는데요. 그때는 데이터베이스 사용법을 몰랐어요. 다 문서에 적혀 있었거든요. 뒤늦게 후회했어요. . . . 다음은 코드입니다.
/*************************************************************************
> File Name: student.cpp
> Author: Tanswer_
> Mail: 98duxm@gmail.com
> Created Time: 2017年05月28日 星期日 16时50分34秒
************************************************************************/
#include <iostream>
#include <string>
#include <stack>
#include <algorithm>
#include <sstream>
#include <mysql/mysql.h>
#include <unistd.h>
using namespace std;
MYSQL mysql;
MYSQL_ROW row;
MYSQL_FIELD* field = NULL;
MYSQL_RES* result;
string IntToStr(int num)
{
stringstream ss;
ss.clear();
ss << num;
return ss.str();
}
void Add()
{
string fname,fsex,ftel,faddr;
int fage;
char choice;
do
{
┊ cout << "请依次输入以下信息：" << endl;
┊ cout << "\nName: ";cin >> fname;
┊ cout << "\nSex: ";cin >> fsex;
┊ cout << "\nAge: "; cin >> fage;
┊ cout << "\nTel: "; cin >> ftel;
┊ cout << "\nAddr: "; cin >> faddr;
┊ string sql = "INSERT INTO Infor (name,sex,tel,addr,age) values('"+fname+"','"+fsex+"','"+ftel+"','"+faddr+"', "+IntToStr(fage)+");";
┊ //string sql = "INSERT INTO Infor (name,sex,age,tel,addr) values('小红','女',18,'13333333333', '陕西省西安市雁塔区');";
┊ mysql_query(&mysql,sql.c_str());
┊ ┊
┊ cout << "是否继续添加(y/n)？： ";
┊ cin >> choice;
}while(choice == 'y');
}
void Select()
{
int id;
cout << "请输入要查询学生的学号: ";
cin >> id;
string sql = "SELECT * FROM Infor WHERE id = "+IntToStr(id)+";";
mysql_query(&mysql,sql.c_str());
result = mysql_store_result(&mysql);
if(result == NULL)
┊ cout << "fail\n";
for(int i=0; i<mysql_num_fields(result); i++)
{
┊ field = mysql_fetch_field_direct(result,i);
┊ cout << field->name << "\t\t";
}
cout << endl;
row = mysql_fetch_row(result);
while(row != NULL)
{
┊ for(int i=0; i<mysql_num_fields(result); i++)
┊ {
┊ ┊ cout << row[i] << "\t\t";
┊ }
┊ cout << endl;
┊ row = mysql_fetch_row(result);
}
}
void Update()
{
int id;
char choice;
string newaddr;
┊ cout << "请输入要修改同学的学号: ";
┊ cin >> id;
┊ cout << endl << "请输入修改后的地址: ";
┊ cin >> newaddr;
┊ string sql = "UPDATE Infor SET addr = '"+newaddr+"'WHERE id= "+IntToStr(id)+"; ";
┊ mysql_query(&mysql,sql.c_str());
┊
}
int main()
{
char choice[5];
mysql_init(&mysql);
/*连接数据库*/
if(!mysql_real_connect(&mysql,"localhost","root","dxm242012","Student",0,NULL,0))
{
┊ cout << "connect fial\n";
┊ return -1;
}
while(atoi(choice) != 'q')
{
┊ sleep(4);
┊ system("clear");
┊ cout << "1.添加学生信息" << endl;
┊ cout << "2.查询学生信息" << endl;
┊ cout << "3.修改学生信息" << endl;
┊ cin >> choice;
┊ cout << choice << endl;
┊ switch(atoi(choice))
┊ {
┊ ┊ case 1:
┊ ┊ ┊ Add();
┊ ┊ ┊ break;
┊ ┊ case 2:
┊ ┊ ┊ Select();
┊ ┊ ┊ break;
┊ ┊ case 3:
┊ ┊ ┊ Update();
┊ ┊ ┊ break;
┊ ┊ default:
┊ ┊ ┊ break;
┊ }
}
mysql_close(&mysql);
return 0;
}MyDB 클래스의 C++ 캡슐화
나중에 이러한 함수는 나중에 쉽게 사용할 수 있도록 간단히 캡슐화되었습니다.
/*************************************************************************
> File Name: myDB.h
> Author: Tanswer_
> Mail: 98duxm@gmail.com
> Created Time: 2017年05月28日 星期日 22时26分22秒
************************************************************************/
#ifndef _MYDB_H
#define _MYDB_H
#include <string>
#include <iostream>
#include <mysql/mysql.h>
using namespace std;
class MyDB
{
public:
MyDB();
~MyDB();
bool InitDB(string host,string user,string pwd,string dbname);
bool ExeSQL(string sql);
private:
MYSQL* mysql;
MYSQL* mysql;
MYSQL_ROW row;
MYSQL_RES* result;
MYSQL_FIELD* field;
};
#endif
/*************************************************************************
> File Name: myDB.cpp
> Author: Tanswer_
> Mail: 98duxm@gmail.com
> Created Time: 2017年05月28日 星期日 22时27分18秒
************************************************************************/
#include <iostream>
#include <string>
#include <stack>
#include <algorithm>
#include <mysql/mysql.h>
#include "myDB.h"
using namespace std;
MyDB::MyDB()
{
mysql = mysql_init(NULL);
if(mysql == NULL)
{
┊ cout << "Error: " << mysql_error(mysql);
┊ exit(-1);
}
}
MyDB::~MyDB()
{
if(!mysql)
{
┊ mysql_close(mysql);
}
}
bool MyDB::InitDB(string host,string user,string pwd,string dbname)
{
/*连接数据库*/
if(!mysql_real_connect(mysql,host.c_str(),user.c_str(),pwd.c_str(),dbname.c_str(),0,NULL,0))
{
┊ cout << "connect fial: " << mysql_error(mysql);
┊ exit(-1);
}
return true;
}
bool MyDB::ExeSQL(string sql)
{
/*执行失败*/
if(mysql_query(mysql,sql.c_str()))
{
┊ cout << "query fail: " << mysql_error(mysql);
┊ exit(1);
}
else
{
┊ /*获取结果集*/
┊ result = mysql_store_result(mysql);
┊ int fieldnum = mysql_num_fields(result);
┊ for(int i=0; i<fieldnum; i++)
┊ {
┊ ┊ row = mysql_fetch_row(result);
┊ ┊ if(row <= 0)
┊ ┊ ┊ break;
┊ ┊ for(int j=0; j<fieldnum; j++)
┊ ┊ {
┊ ┊ ┊ cout << row[j] << "\t\t";
┊ ┊ }
┊ ┊ cout << endl;
┊ }
┊ mysql_free_result(result);
}
return true;
}
/*************************************************************************
> File Name: main.cpp
> Author: Tanswer_
> Mail: 98duxm@gmail.com
> Created Time: 2017年05月28日 星期日 22时53分43秒
************************************************************************/
#include <iostream>
#include <string>
#include <stack>
#include <algorithm>
#include <mysql/mysql.h>
#include "myDB.h"
using namespace std;
int main()
{
MyDB db;
db.InitDB("localhost","root","xxxxxx","Student");
db.ExeSQL("SELECT * FROM Infor;");
return 0;
}실행 결과는 다음과 같습니다.
다음은 발생한 문제입니다.
1. 컴파일하는 동안 오류가 발생했습니다.
해당 파일이나 디렉터리가 없습니다.
#include<mysql/mysql.h> ^
컴파일이 중단되었습니다.
해결책: mysql-client 및 mysql-server 외에도 installmysql-devel을 설치하면 문제가 해결됩니다.
2. 사용자 정의 변수가 SQL 문에 전달되면 문제가 발생합니다
在网上查找到这样一种格式，
string sql = "INSERT INTO Infor (name,sex,tel,addr,age) values('"+fname+"','"+fsex+"','"+ftel+"','"+faddr+"', "+IntToStr(fage)+");";
然后string类型的可以成功，整型的变量还是不行，我又写了个函数把int转为string。
string IntToStr(int num)
{
stringstream ss;
ss.clear();
ss << num;
return ss.str();
}위 내용은 Linux에서 Mysql 데이터베이스의 C++ 작업을 구현하는 방법에 대한 자세한 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!