MySQL快速入门使用

2021-03-25 本文已影响0人 _张鹏鹏_

概念：

SQL 是用于访问和处理数据库的标准的计算机语言。全称为Structured Query Language，即结构化查询语言。

准备工作：

可以按照MySQL 安装教程安装MySQL数据库。

数据库连接工具可以使用HeidiSql。

在window cmd下的常用操作：

net start mysql   # 启动服务
net stop mysql    # 停止服务
mysql -u root -p  # 在命令行中连接到数据库
ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY '你的新密码';  #修改MySQL密码

语法：

SQL 对大小写不敏感！

可以把 SQL 分为两个部分：数据操作语言 (DML) 和数据定义语言 (DDL)。

查询和更新指令构成了 SQL 的 DML 部分：

SELECT - 从数据库表中获取数据
UPDATE - 更新数据库表中的数据
DELETE - 从数据库表中删除数据
INSERT INTO - 向数据库表中插入数据

SQL 的数据定义语言 (DDL) 部分使我们有能力创建或删除表格。我们也可以定义索引（键），规定表之间的链接，以及施加表间的约束。

SQL 中最重要的 DDL 语句:

CREATE DATABASE - 创建新数据库
ALTER DATABASE - 修改数据库
CREATE TABLE - 创建新表
ALTER TABLE - 变更（改变）数据库表
DROP TABLE - 删除表
CREATE INDEX - 创建索引（搜索键）
DROP INDEX - 删除索引

常用语句参考：MySQL 基本语法

C++ API：

使用 MySQL提供的接口时，只需要包含mysql.h这个文件，该文件还包含了其他的头文件，所以项目还需要将其他文件添加进来。

以下是高频使用的C++ API：

mysql_init
mysql_real_connect
mysql_close

mysql_query
mysql_real_query
mysql_store_result
mysql_free_result

mysql_fetch_row


mysql_error

其他的一些接口：

mysql_select_db
mysql_num_rows

示例：

main：

int main(int argc, char **argv)
{
    MySQLDB &db = MySQLDB::getInstance();

    DBInfo dbInfo;
    dbInfo.setDBName("test");
    dbInfo.setHost("localhost");
    dbInfo.setPassword("admin123");
    dbInfo.setPort(3306);
    dbInfo.setUserName("root");
    db.connect(dbInfo);

    db.createDataBase("test");

    db.ROLE(StudentsTable).createTable();
    db.isTableExist("students");

    db.ROLE(StudentsTable).add(Student(11, 1, "daniel", 'M', 90));

    db.ROLE(StudentsTable).modify(Student(11, 1, "daniel", 'M', 95));


    list<Student> students;
    db.ROLE(StudentsTable).getAll(students);
    for (auto &student : students)
    {
        printf("##########");
        student.dump();
        printf("##########");
    }

    db.ROLE(StudentsTable).remove(Student(11, 1, "daniel", 'M', 95));

    db.ROLE(StudentsTable).destoryTable();

    db.disconnect();

    system("pause");
    return 0;
}

MySQLDB：

struct MySQLDB: private StudentsTable
{
    static MySQLDB& getInstance();
    void disconnect();
    bool connect(const DBInfo &dbInfo);
    bool createDataBase(const char *name);
    bool isTableExist(const char *name);
    IMPL_ROLE(StudentsTable)
private:
    MYSQL *getHandle() override;
private:
    MySQLDB();
    MySQLDB(const MySQLDB&);
    MySQLDB& operator=(const MySQLDB&);
private:
    MYSQL *handle;
    DBInfo dbInfo;
};

MySQLDB::MySQLDB() :handle(NULL)
{
 
}

MySQLDB& MySQLDB::getInstance()
{
    static MySQLDB db;
    return db;
}

MYSQL *MySQLDB::getHandle()
{
    return handle;
}

void MySQLDB::disconnect()
{
    mysql_close(handle);
}

bool MySQLDB::connect(const DBInfo &dbInfo)
{
    this->dbInfo = dbInfo;

    handle = new MYSQL();
    if (handle == NULL)
        return false;

    mysql_init(handle);

    bool failed = (mysql_real_connect(handle, dbInfo.host, dbInfo.userName, dbInfo.passWord, NULL, dbInfo.port, NULL, 0) == NULL);
    if (failed)
    {
        printf("connected database failed, error :%s", mysql_error(handle));
        return false;
    }
    //防止乱码。设置和数据库的编码一致就不会乱码
    mysql_query(handle, "set names gbk");
    return true;
}

bool MySQLDB::createDataBase(const char *name)
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "CREATE DATABASE IF NOT EXISTS %s;", name);
    bool succ = (mysql_real_query(handle, sql, strlen(sql) + 1) == 0);
    if (!succ)
    {
        printf("create database failed, %s\n", mysql_error(handle));
        return false;
    }

    sprintf(sql, "USE %s;", name);  //后面操作都在这个数据库里面操作;
    succ = (mysql_real_query(handle, sql, strlen(sql) + 1) == 0);
    if (!succ)
    {
        printf("use database failed, %s\n", mysql_error(handle));
        return false;
    }
    return true;
}

bool MySQLDB::isTableExist(const char *name)
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "SELECT 1 FROM %s.%s", dbInfo.dBName, name);
    bool exist = (mysql_real_query(handle, sql, strlen(sql) + 1) == 0);

    // 以释放目前mysql数据库query返回所占用的内存
    MYSQL_RES* results = mysql_store_result(handle);
    mysql_free_result(results);
    return exist;
}

StudentsTable：

struct Student
{
    Student(int id, int classId, const char* name, char gender, int score)
    {
        this->id = id;
        this->classId = classId;
        strcpy(this->name,name);
        this->gender = gender;
        this->score = score;
    }

    void dump() const
    {
        printf("\nid: %u\n",id);
        printf("class id: %u\n", classId);
        printf("name: %s\n", name);
        printf("gender: %c\n", gender);
        printf("score: %u\n", score);
    }

    void setValue(const MYSQL_ROW& row)
    {
        S32 nIndex = 0;
        this->id = strtoul(row[nIndex++], 0, 10);
        this->classId = strtoul(row[nIndex++], 0, 10);
        strcpy(this->name, row[nIndex++]);
        this->gender = *row[nIndex++];
        this->score = strtoul(row[nIndex], 0, 10);
    }

    Student(){}
    int id;
    int classId;
    char name[100];
    char gender;
    int score;
};

struct StudentsTable
{
    bool createTable();
    bool destoryTable();

    bool add(const Student& s);
    bool remove(const Student& s);
    bool modify(const Student& s);
    bool clear();
    bool getAll(list<Student> &students);
private:
    virtual  MYSQL *getHandle() = 0;
private:
    bool query(const char* sql);
};

bool StudentsTable::query(const char* sql)
{
    MYSQL *handle = getHandle();
    if (handle == NULL)
        return false;

    bool succ = (mysql_query(handle, sql) == 0);
    if (!succ)
    {
        cout << mysql_error(handle) << endl;
    }
    return succ;
}

bool StudentsTable::createTable()
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "CREATE TABLE IF NOT EXISTS students(id BIGINT NOT NULL AUTO_INCREMENT,\
                  class_id BIGINT NOT NULL,\
                  name VARCHAR(100) NOT NULL,\
                  gender VARCHAR(1) NOT NULL,\
                  score INT NOT NULL,\
                  PRIMARY KEY(id));");
    return query(sql);
}

bool StudentsTable::destoryTable()
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "DROP TABLE students");
    return query(sql);
}

bool StudentsTable::add(const Student& s)
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "INSERT INTO students(id, class_id, name, gender, score) VALUES (\
                 %u, %u, '%s', '%c', %u);",\
                 s.id, s.classId, s.name, s.gender, s.score);
    return query(sql);
}

bool StudentsTable::remove(const Student& s)
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "DELETE FROM students WHERE id=%d", s.id);
    return query(sql);
}

bool StudentsTable::modify(const Student& s)
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "UPDATE students SET class_id=%u, name='%s', gender='%c', score=%u WHERE id=%u;",\
            s.classId, s.name, s.gender, s.score, s.id);
    return query(sql);
}

bool StudentsTable::clear()
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "DELETE FROM students;");
    return query(sql);
}


bool StudentsTable::getAll(list<Student> &students)
{
    S8 sql[1024] = { 0 };
    sprintf(sql, "SELECT * FROM students;");

    MYSQL *handle = getHandle();
    if (handle == NULL)
        return false;

    bool succ = (mysql_query(handle, sql) == 0);
    if (!succ)
    {
        cout << mysql_error(handle) << endl;
        return false;
    }

    MYSQL_RES* res = mysql_store_result(handle);
    if (!res)
    {
        return false;
    }

    MYSQL_ROW row;
    Student info;
    while (row = mysql_fetch_row(res))
    {
        info.setValue(row);
        students.push_back(info);
    }
    mysql_free_result(res);
    return true;
}

demo代码链接：https://github.com/yanxicheung/daydayup/tree/main/MySQL/demo

MySQL快速入门使用

概念：

准备工作：

语法：

C++ API：

示例：

main：

MySQLDB：

StudentsTable：

参考文献：

猜你喜欢

热点阅读