当前位置: 首页 > news >正文

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, "退出", "断开成功");
}

http://www.lryc.cn/news/163813.html

相关文章:

  • Java程序中常用的设计模式有哪些和该种设计模式解决的痛点
  • Android12之解析/proc/pid进程参数(一百六十四)
  • 正儿八经的雅思口语盘丝洞大法学习总结(长期修改更新)针对23.9月考生
  • 算法竞赛入门【码蹄集新手村600题】(MT1260-1280)C语言
  • qt连接tcp通信和连接数据库
  • MySQL Oracle区别
  • Figma实用插件速收藏!精选19个干货插件大公开!
  • 【STM32】FSMC—扩展外部 SRAM 初步使用 1
  • 保姆级教程 --redis启动命令
  • 【C++】构造函数分类 ① ( 构造函数分类简介 | 无参构造函数 | 有参构造函数 | 拷贝构造函数 | 代码示例 - 三种类型构造函数定义与调用 )
  • 胡焕庸线,我国东西地级市分布密度分界线
  • 里氏替换原则在继承关系中子类对父类方法的重写(覆盖)或重载时应遵循的规则
  • 【脑机接口开源数据处理包】brainflowBrainFlow是一个库,旨在获取,解析和分析脑电图,肌电图,心电图和其他类型的数据从生物传感器。
  • #452. 序列操作
  • 《Python深度学习-Keras》精华笔记3:解决深度学习多分类问题
  • 区块链世界的大数据入门之zkMapReduce简介
  • Python流程控制语句-条件判断语句练习及应用详解
  • (十)ElasticSearch高级使用【别名,重建索引,refresh操作,高亮查询,查询建议】
  • 基于小波神经网络的中药材价格预测,基于ANN的小波神经网络中药材价格预测
  • thinkPhp5返回某些指定字段
  • 基于docker环境的tomcat开启远程调试
  • ELK日志框架图总结
  • go 每天定时任务 --chatGPT
  • Lightdb 23.3 plorasql函数支持DML
  • 电容笔值不值得买?开学季比较好用的电容笔
  • Mybatis 框架 ( 五 ) 分页
  • Python模板注入
  • Java常用的设计模式
  • 攻防世界-WEB-Web_php_include
  • angular中多层嵌套结构的表单如何处理回显问题