QT 第五天 TCP通信与数据库

一、数据库增删改查

QT       += core gui sqlgreaterThan(QT_MAJOR_VERSION, 4): QT += widgetsCONFIG += c++11# The following define makes your compiler emit warnings if you use
# any Qt feature that has been marked deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the
# deprecated API in order to know how to port your code away from it.

.h

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QSqlDatabase>   //数据库管理类
#include <QSqlQuery>      //执行sql语句对应的类
#include <QSqlRecord>     //纪录类
#include <QMessageBox>
#include <QDebug>QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_inputBtn_clicked();void on_showBtn_clicked();void on_searchBtn_clicked();void on_deleteBtn_clicked();private:Ui::Widget *ui;//定义一个数据对象QSqlDatabase db;
};
#endif // WIDGET_H

.cpp

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//判断数据库对象是否包含了自己使用的数据库Student.dbif(!db.contains("Student.db")){//添加一个数据库//函数原型：//参数：//返回值：db = QSqlDatabase::addDatabase("QSQLITE"); //表明使用的是sqlite3版本数据库//给数据库命名db.setDatabaseName("Student.db");}//打开数据库if(!db.open()){QMessageBox::information(this,"提示","数据库打开失败");return;}//此时说明数据库已经创建出来并打开了，就可以创建数据表了//创建数据表需要使用sql语句，需要使用QSQLQuerry类对象来完成//准备sql语句QString sql = "create table if not exists myTable("              //创建表的sql语句"id integer primary key autoincrement,"          //id主键，允许自增"numb integer,"                                   //学号，是整形"name varchar(10),"                               //姓名   字符串"score integer,"                                  //分数是整形"sex varchar(4))";                                 //性别 字符串//定义语句执行者QSqlQuery querry;//使用querry执行sql语句if(!querry.exec(sql)){QMessageBox::information(this,"失败","创建表失败");}else{QMessageBox::information(this,"成功","创建表成功");}
}Widget::~Widget()
{delete ui;
}//录入按钮对应的槽函数
void Widget::on_inputBtn_clicked()
{//获取ui界面中要存入的数据int numb_ui = ui->numbEdit->text().toInt();   //获取ui界面的学号QString name_ui = ui->nameEdit->text();       //获取ui界面的姓名int score_ui = ui->scoreEdit->text().toUInt();  //获取ui界面上的成绩QString sex_ui = ui->sexEdit->text();          //获取ui界面的性别//判断是否有漏填数据if(numb_ui == 0 || name_ui.isEmpty() || score_ui == 0 || sex_ui.isEmpty()){QMessageBox::information(this,"提示","请将信息填写完整");}//准备sql语句QString sql = QString("insert into myTable(numb,name,score,sex)""values(%1,'%2',%3,'%4')").arg(numb_ui).arg(name_ui).arg(score_ui).arg(sex_ui);//定义语句执行QSqlQuery querry;//调用执行者的相关函数执行sql语句if(!querry.exec(sql)){QMessageBox::information(this,"失败","插入数据失败");}else{QMessageBox::information(this,"成功","插入数据成功");}
}
//展示按钮对应的槽函数
void Widget::on_showBtn_clicked()
{//准备sql语句QString sql = "select * from myTable";//准备语句执行者QSqlQuery querry;//执行sql语句if(!querry.exec(sql)){QMessageBox::information(this,"失败","查询失败");return;}//此时，将查找到的所有结果，全部放在querry对象中了//可以通过next函数不断遍历查询结果int i = 0;   //记录行号while(querry.next()){//此时，遍历的就是任意一组记录：querry.record//qDebug() << querry.record();//要找到每条，记录中的每个数据使用querry.record().value(i)//qDebug() << querry.record().value(2);//querry.record().count()  //返回当前记录对应数据项的个数//querry.record().value(2).toString();  //将记录的某一项的数据转变成字符串//将数据库中的表格展示到ui界面//ui->tableWidget->setItem()for(int j = 0; j < querry.record().count()-1; j++){ui->tableWidget->setItem(i,j,new QTableWidgetItem(querry.record().value(j+1).toString()));}i++;  //进行下一行}
}
//查找按钮对应的槽函数
void Widget::on_searchBtn_clicked()
{//准备sql语句QString sql = "select * from myTable where numb = 1001";//准备语句执行者QSqlQuery querry;//执行sql语句if(!querry.exec(sql)){QMessageBox::information(this,"失败","查询失败");}else{QMessageBox::information(this,"成功","查询成功");}}
//删除按钮对应的槽函数
void Widget::on_deleteBtn_clicked()
{//准备sql语句//  QString sql = "delete from myTable where name = 'damei'";  //删除某一个QString sql = "delete from myTable";   //全部删除//准备语句执行者QSqlQuery querry;//执行sql语句if(!querry.exec(sql)){QMessageBox::information(this,"删除","删除失败");}else{QMessageBox::information(this,"删除","删除成功");}}

ui

二.TCP通信

server

QT       += core gui networkgreaterThan(QT_MAJOR_VERSION, 4): QT += widgetsCONFIG += c++11# The following define makes your compiler emit warnings if you use
# any Qt feature that has been marked deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the
# deprecated API in order to know how to port your code away from it.
DEFINES += QT_DEPRECATED_WARNINGS

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpServer>  //服务器头文件
#include <QTcpSocket>  //客户端头文件
#include <QList>       //链表头文件，用来存放客户端容器
#include <QDebug>
#include <QMessageBox> //消息对话框类QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_strartBtn_clicked();void newConnection_slot();  //每当有一个新的客户端发送信号进行连接时，则进入该槽函数处理相关逻辑//如果该套接字有数据项服务器发送过来，那么该套接字就会自动发射一个readyRead信号//我们可以将该信号连接到自定义的槽函数中处理相关逻辑void readyRead_slot();     //private:Ui::Widget *ui;//1.定义服务器指针QTcpServer *server;//4.定义客户端指针链表容器QList<QTcpSocket *>clientList;};
#endif // WIDGET_H

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//1.给服务器实例化一个对象server = new QTcpServer(this);  //此时创建服务器成功
}Widget::~Widget()
{delete ui;
}//2.启动按钮对应的槽函数，只有点击启动按钮后，才可以发射一个信号将服务器设置为监听状态
void Widget::on_strartBtn_clicked()
{//获取ui界面上的端口号，在监听前后设置都可以quint16 port = ui->portEdit->text().toInt();  //toInt 是将里面的文本转换为整型//将服务器设置为监听状态//bool QTcpServer::listen(const QHostAddress &address = QHostAddress::Any, quint16 port = 0)//参数一：要监听的主机地址，如果是any,表示监听所有主机地址，也可以给定特定的主机地址进行监听//参数二：通过指定的端口号进行访问服务器，如果是0，则表示由服务器自动分配，如果非0，则表示指定端口号//返回值：成功返回真，失败返回假if(!server->listen(QHostAddress::Any,port)){QMessageBox::critical(this,"失败","服务器启动失败");return;}else{QMessageBox::information(this,"成功","服务器启动成功");}//此时表明服务器启动成功，并对客户端连接进行监听//如果有客户端向服务器发来连接请求，那么该服务器就会自动发射一个newConnection的信号//我们可以将该信号连接到对应的槽函数中处理相关逻辑//3.进行服务器客户端连接，每当新的客户端发送过来一个连接信号，则进行一次连接//如果写在构造函数中只会连接一次所以不能写在构造函数中，要写在自定义的槽函数中connect(server,&QTcpServer::newConnection,this,&Widget::newConnection_slot);}
//4.处理newConnection信号的槽函数实现
void Widget::newConnection_slot()
{qDebug() << "有新的客户端发来连接请求了";//4.获取最新连接的客户端的套接字//函数原型：[virtual] QTcpSocket *QTcpServer::nextPendingConnection()//参数：无//返回值：最新连接客户端套接字指针QTcpSocket *s = server->nextPendingConnection();//4.将获取的套接字存放到客户端容器中clientList.push_back(s);   //进行尾插//5.此时，服务器已经和客户端建立连接请求了//如果有客户端向服务器发来数据，那么对于的客户端套接字就会发射一个readyRead的信号//我们可以将该信号连接到自定义的槽函数中处理相关逻辑connect(s,&QTcpSocket::readyRead,this,&Widget::readyRead_slot);
}
void Widget::readyRead_slot()
{//6.进行循环遍历删除客户端链表中的无效客户端套接字for(int i = 0;i<clientList.count();i++){//判断套接字状态//函数原型：SocketState state() const;//功能：返回客户端套接字的状态//参数：无//返回值：客户端的状态，如果结果为0，表示未连接if(clientList[i]->state() == 0){clientList.removeAt(i);   //将下标为i的客户端移除掉}}//7.循环遍历所有客户端，查看是哪个客户端发来的数据for(int i = 0;i<clientList.count();i++){//函数原型：qint64 bytesAvailable() const override;//功能：返回当前客户端套接字中的可读数据字节个数//参数：无//返回值：当前客户端待读的字节数，如果该数据为0，表示无待读数据if(clientList[i]->bytesAvailable()!=0){//读取当前客户端的相关数据//函数原型：QByteArray readAll();//功能：读取当前套接字中的所有数据，并返回一个字节数组//参数：无//返回值：数据的字节数组QByteArray msg = clientList[i]->readAll();//将数据展示到ui界面上//把本机字符串转换为Qstring类型的字符串ui->msgList->addItem(QString::fromLocal8Bit(msg));//将接收到的该消息，发送给所有客户端for(int j = 0;j<clientList.count();j++){clientList[j]->write(msg);}}}
}

cli

QT       += core gui networkgreaterThan(QT_MAJOR_VERSION, 4): QT += widgetsCONFIG += c++11# The following define makes your compiler emit warnings if you use
# any Qt feature that has been marked deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the
# deprecated API in order to know how to port your code away from it.
DEFINES += QT_DEPRECATED_WARNINGS

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpSocket>   //客户端头文件
#include <QMessageBox>  //消息对话框类QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void readyRead_slot();void connected_slot();void on_sendBtn_clicked();void on_connectBtn_clicked();void on_disconnectBtn_clicked();void disconnected_slot();private:Ui::Widget *ui;//定义一个客户端指针QTcpSocket *socket;//用户名QString userName;
};
#endif // WIDGET_H

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//给客户端指针实例化空间socket = new QTcpSocket(this);//如果连接服务器成功，该客户端就会发射一个connected的信号，//我们可以将该信号连接到自定义的槽函数中处理相关逻辑//由于该连接只需连接一次，所以，写在构造函数中即可connect(socket, &QTcpSocket::connected, this, &Widget::connected_slot);//客户端与服务器连接成功后，如果服务器向客户端发来数据，那么该客户端就会自动发射一个readyRead信号//我们可以将该信号连接到自定义的槽函数中处理相关逻辑connect(socket, &QTcpSocket::readyRead, this, &Widget::readyRead_slot);//当客户端与服务器断开连接后，该客户端就会自动发射一个disconnected的信号//我们可以将该信号与自定义的槽函数连接//由于只需要连接一次，所以将该连接写到构造函数中即可connect(socket, &QTcpSocket::disconnected, this, &Widget::disconnected_slot);
}Widget::~Widget()
{delete ui;
}void Widget::on_connectBtn_clicked()
{//获取ui界面的信息userName = ui->userNameEdit->text();        //获取用户名QString hostName = ui->ipEdit->text();       //获取主机地址quint16 port = ui->portEdit->text().toUInt();  //获取端口号//调用函数连接到主机//函数原型：[virtual] void QAbstractSocket::connectToHost(const QString &hostName, quint16 port)//参数1：服务器的主机地址//参数2：端口号//返回值：无socket->connectToHost(hostName, port);//如果连接服务器成功，该客户端就会发射一个connected的信号，//我们可以将该信号连接到自定义的槽函数中处理相关逻辑//由于该连接只需连接一次，所以，写在构造函数中即可
}
//关于处理connected信号的槽函数的定义
void Widget::connected_slot()
{QMessageBox::information(this, "成功", "连接服务器成功");//顺便向服务器发送一条消息，说：***：进入聊天室QString msg = userName + ": 进入聊天室";socket->write(msg.toLocal8Bit());
}
//关于readyRead信号对应槽函数的实现
void Widget::readyRead_slot()
{//读取该客户端中的数据QByteArray msg = socket->readAll();//将数据展示在ui界面ui->msgList->addItem(QString::fromLocal8Bit(msg));
}//发送按钮对应的槽函数
void Widget::on_sendBtn_clicked()
{//获取UI界面中的编辑的文本内容QString m = ui->msgEdit->text();//整合要发送的信息QString msg = userName + ": " + m;//将消息发送给服务器socket->write(msg.toLocal8Bit());//将消息编辑框中的内容清空ui->msgEdit->clear();
}//断开服务器按钮对应的槽函数
void Widget::on_disconnectBtn_clicked()
{//准备要发送的信息QString msg = userName +": 离开聊天室";socket->write(msg.toLocal8Bit());//调用成员函数disconnectFromHost//函数原型：virtual void disconnectFromHost();//功能：断开客户端与服务器的连接//参数：无//返回值：无socket->disconnectFromHost();//当客户端与服务器断开连接后，该客户端就会自动发射一个disconnected的信号//我们可以将该信号与自定义的槽函数连接//由于只需要连接一次，所以将该连接写到构造函数中即可}
//disconnected信号对应槽函数的实现
void Widget::disconnected_slot()
{QMessageBox::information(this, "退出", "断开成功");
}