Python3访问MySQL数据库快速入门Demo

要实现一个简单的IM（即时通讯）系统，支持用户注册、登录和聊天记录存储，你可以使用Python和mysql数据库。以下是一个基本的实现示例： 要使用MySQL创建表并通过Python提供一个API服务，你可以使用Flask框架来实现API服务，并使用PyMySQL库来连接MySQL数据库。以下是一个基本的实现步骤：

1. 安装所需库

首先，确保你安装了Flask和PyMySQL库：

pip install flask pymysql

2. MySQL数据库设置

docker run --hostname=a5ddc3708f2e --env=MYSQL_ROOT_PASSWORD=123456 --env=MYSQL_DATABASE=jwordpress --env=TZ=Asia/Shanghai --env=LANG=en_US.UTF-8 --env=PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin --env=GOSU_VERSION=1.7 --env=MYSQL_MAJOR=5.7 --env=MYSQL_VERSION=5.7.26-1debian9 --volume=D:\IdeaProjects\Jwordpress-parent-s02-81f3dea303558f4388ef39435a52ea1cfab22904\docker\mysql\my.cnf:/etc/mysql/my.cnf:rw --volume=D:\IdeaProjects\Jwordpress-parent-s02-81f3dea303558f4388ef39435a52ea1cfab22904\docker\mysql\init-file.sql:/etc/mysql/init-file.sql:rw --volume=D:\IdeaProjects\Jwordpress-parent-s02-81f3dea303558f4388ef39435a52ea1cfab22904\docker\mysql\data:/var/lib/mysql:rw --volume=D:\IdeaProjects\Jwordpress-parent-s02-81f3dea303558f4388ef39435a52ea1cfab22904\docker\mysql\docker-entrypoint-initdb.d:/docker-entrypoint-initdb.d:rw --volume=/var/lib/mysql --network=docker_default -p 3306:3306 --restart=unless-stopped --label='com.docker.compose.config-hash=f33622a4d32e092d39a39c3dc0bd2259df09b24ad897567bcaa7f7fa0630b019' --label='com.docker.compose.container-number=1' --label='com.docker.compose.depends_on=' --label='com.docker.compose.image=sha256:a1aa4f76fab910095dfcf4011f32fbe7acdb84c46bb685a8cf0a75e7d0da8f6b' --label='com.docker.compose.oneoff=False' --label='com.docker.compose.project=docker' --label='com.docker.compose.project.config_files=D:\IdeaProjects\Jwordpress-parent-s02-81f3dea303558f4388ef39435a52ea1cfab22904\docker\docker-compose.yml' --label='com.docker.compose.project.working_dir=D:\IdeaProjects\Jwordpress-parent-s02-81f3dea303558f4388ef39435a52ea1cfab22904\docker' --label='com.docker.compose.service=mysql' --label='com.docker.compose.version=2.21.0' --runtime=runc -d registry.cn-hangzhou.aliyuncs.com/zhengqing/mysql:5.7

假设你已经在MySQL中创建了一个数据库，接下来创建用户和消息表。

CREATE DATABASE chat_db;USE chat_db;CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY,username VARCHAR(255) UNIQUE NOT NULL,password VARCHAR(255) NOT NULL
);CREATE TABLE messages (id INT AUTO_INCREMENT PRIMARY KEY,sender VARCHAR(255) NOT NULL,receiver VARCHAR(255) NOT NULL,message TEXT NOT NULL,timestamp DATETIME DEFAULT CURRENT_TIMESTAMP
);

3. 创建Flask API服务

一个简单的Flask应用，提供注册、登录和发送消息的API。 详见main.py

from flask import Flask, request, jsonify
import pymysql
import bcryptapp = Flask(__name__)# Database connection configuration
db_config = {'host': 'localhost','user': 'root','password': '123456','database': 'chat_db'
}def get_db_connection():return pymysql.connect(**db_config)@app.route('/register', methods=['POST'])
def register():data = request.jsonusername = data['username']password = data['password']hashed = bcrypt.hashpw(password.encode('utf-8'), bcrypt.gensalt())conn = get_db_connection()cursor = conn.cursor()try:cursor.execute("INSERT INTO users (username, password) VALUES (%s, %s)", (username, hashed))conn.commit()return jsonify({'message': 'Registration successful!'}), 201except pymysql.IntegrityError:return jsonify({'message': 'Username already exists!'}), 400finally:cursor.close()conn.close()@app.route('/login', methods=['POST'])
def login():data = request.jsonusername = data['username']password = data['password']conn = get_db_connection()cursor = conn.cursor()try:cursor.execute("SELECT password FROM users WHERE username = %s", (username,))result = cursor.fetchone()if result and bcrypt.checkpw(password.encode('utf-8'), result[0].encode('utf-8')):return jsonify({'message': 'Login successful!'}), 200else:return jsonify({'message': 'Incorrect username or password!'}), 401finally:cursor.close()conn.close()@app.route('/send_message', methods=['POST'])
def send_message():data = request.jsonsender = data['sender']receiver = data['receiver']message = data['message']conn = get_db_connection()cursor = conn.cursor()cursor.execute("INSERT INTO messages (sender, receiver, message) VALUES (%s, %s, %s)", (sender, receiver, message))conn.commit()cursor.close()conn.close()return jsonify({'message': 'Message sent successfully!'}), 201@app.route('/get_messages', methods=['GET'])
def get_messages():user1 = request.args.get('user1')user2 = request.args.get('user2')conn = get_db_connection()cursor = conn.cursor()cursor.execute('''SELECT sender, receiver, message, timestamp FROM messages WHERE (sender = %s AND receiver = %s) OR (sender = %s AND receiver = %s)ORDER BY timestamp''', (user1, user2, user2, user1))messages = cursor.fetchall()cursor.close()conn.close()return jsonify(messages), 200if __name__ == '__main__':app.run(debug=True)

4. 运行API服务

将上述代码保存为一个Python文件（例如main.py），然后运行：

python main.py

这将启动一个Flask开发服务器，你可以通过POST请求来注册和登录用户，通过GET请求来获取聊天记录。

5. 测试

post http://127.0.0.1:5000/register

{"username": "alice","password": "password123"
}

post http://127.0.0.1:5000/register

{"username": "bob","password": "password123"
}

post http://127.0.0.1:5000/send_message

{"sender": "alice","receiver": "bob","message": "Hello Bob!"
}

get http://127.0.0.1:5000/get_messages?user1=alice&user2=bob

[["alice","bob","Hello Bob!","Fri, 15 Nov 2024 16:06:33 GMT"]
]

请注意，这个示例是一个基本实现，适用于学习和测试。在生产环境中，你需要考虑更多的安全性和性能优化，例如使用HTTPS、添加身份验证令牌等。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.xdnf.cn/news/18747.html

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

【Linux】虚拟地址空间，页表，物理内存

【Linux】虚拟地址空间，页表，物理内存

目录 进程地址空间，页表，物理内存 什么叫作地址空间？ 如何理解地址空间的区域划分？ 地址空间结构体 为什么要有地址空间？ 页表 cr3寄存器 权限标记位 位置标记位 其他 每个存储单元是一个字节，一…
阅读更多...
集群聊天服务器(3)muduo网络库

集群聊天服务器(3)muduo网络库

目录 基于muduo的客户端服务器编程 muduo只能装在linux中，依赖boost库 客户端并不需要高并发 基于muduo的客户端服务器编程 支持epoll线程池，muduo封装了线程池 而且还有完善的日志系统 使用muduo库代码非常固定，基本就只有chatserver的类名…
阅读更多...
【Python刷题】最少拐弯路线问题

【Python刷题】最少拐弯路线问题

题目描述 洛谷P1649 一、题目理解 首先，我们来看一下这道题目的要求。题目给定了一个 NN（1≤N≤100） 的方格，方格中的每个格子有不同的状态，用 . 表示可以行走的格子，x 表示不能行走的格子，…
阅读更多...
在windows系统里面部署 Redis

在windows系统里面部署 Redis

在windows中下载安装REdis 1.下载mis 地址添加链接描述 然后直接下载安装然后点击你的库 2.然后选择好之后选择好路径就行了。 然后我们点击这个cli.exe文件然后双击打开输入 在命令框里输入： 如果显示的和图片显示的一样，则证明你已经在本地部署好了…
阅读更多...
NTP博客

NTP博客

使用nmtui命令修改IP： 注意： 修改之后，要激活： nmcli connection up ens160 1、软件安装 #设置当前时区 [rootlocalhost ~]# timedatectl set-timezone Asia/Shanghai 1.1.配置国内阿里yum源 [rootredhat ~]# cd /etc/yum.r…
阅读更多...
《Large-scale Multi-modal Pre-trained Models: A Comprehensive Survey》中文校对版

《Large-scale Multi-modal Pre-trained Models: A Comprehensive Survey》中文校对版

文章汉化系列目录 文章目录 文章汉化系列目录摘要引言2 背景2.1 传统深度学习2.2 自然语言处理中的预训练2.3 计算机视觉中的预训练2.4 音频与语音中的预训练 3 多模态预训练3.1 任务定义与关键挑战3.2 MM-PTM的优势3.3 预训练数据3.4 预训练目标3.5 预训练网络架构3.5.1 自注意…
阅读更多...
从源码角度分析JDK动态代理

从源码角度分析JDK动态代理

文章目录 前言一、JDK动态代理二、动态代理的生成三、invoke的运行时调用总结 前言 本篇从源码的角度，对JDK动态代理的实现，工作原理做简要分析。 一、JDK动态代理 JDK动态代理是运行时动态代理的一种实现，相比较于CGLIB ，目标对象…
阅读更多...
操作系统——计算机系统概述——1.5操作系统引导（开机过程）

操作系统——计算机系统概述——1.5操作系统引导（开机过程）

操作系统引导： A.CPU从一个特定主存地址开始，取指令，执行ROM中的引导程序（先进行硬件自检，再开机） B.将磁盘的第一块——主引导记录读入内存，执行磁盘引导程序，扫描分区表 C.从活动分…
阅读更多...
推荐一本python学习书：《编程不难》

推荐一本python学习书：《编程不难》

推荐理由 全面：把零基础Python编程、可视化、数学、数据、机器学习，融合在一起，循循渐进。 开源：PDF、Python代码、Jupyter文档，在github直接免费下！ 真实：提供大量真实场景下的数据&#xff…
阅读更多...
数据结构与算法分析模拟试题及答案5

数据结构与算法分析模拟试题及答案5

模拟试题（五） 一、单项选择题（每小题 2 分，共20分） （1）队列的特点是（　　　）。 A）先进后出 B）先进先出 C）任意位置进出 D&#xff0…
阅读更多...
集群聊天服务器(9)一对一聊天功能

集群聊天服务器(9)一对一聊天功能

目录 一对一聊天离线消息服务器异常处理 一对一聊天 先新添一个消息码 在业务层增加该业务 没有绑定事件处理器的话消息会派发不出去 聊天其实是服务器做一个中转 现在同时登录两个账号 收到了聊天信息 再回复一下 离线消息 声明中提供接口和方法 张三对离线的李…
阅读更多...
jedis基础入门

jedis基础入门

jedis采用key&#xff0c;value的形式保存数据&#xff0c;使用nosql sql和nosql的区别 一&#xff1a;入门案例 导入依赖 <dependencies><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>…
阅读更多...
QWen2.5学习

QWen2.5学习

配置环境 pip install transformers 记得更新一下&#xff1a;typing_extensions pip install --upgrade typing_extensions 安装modelscope modelscope/modelscope: ModelScope: bring the notion of Model-as-a-Service to life. 下载这个仓库的代码上传到服务器解压 推…
阅读更多...
足球青训俱乐部管理后台系统（程序+数据库+报告）

足球青训俱乐部管理后台系统（程序+数据库+报告）

基于SpringBoot的足球青训俱乐部管理后台系统&#xff0c;系统包含两种角色&#xff1a;管理员、用户,系统分为前台和后台两大模块 编程语言&#xff1a;Java 数据库&#xff1a;MySQL 项目管理工具&#xff1a;Maven 前端技术&#xff1a;Vue 后端技术&#xff1a;SpringBoot…
阅读更多...
MoneyPrinterTurbo - AI自动生成高清短视频

MoneyPrinterTurbo - AI自动生成高清短视频

MoneyPrinterTurbo是一款基于AI大模型的开源软件&#xff0c;旨在通过一键操作帮助用户自动生成高清短视频。只需提供一个视频 主题或 **关键词** &#xff0c;就可以全自动生成视频文案、视频素材、视频字幕、视频背景音乐&#xff0c;然后合成一个高清的短视频。 ​ ​ 主要…
阅读更多...
Cross-Inlining Binary Function Similarity Detection

Cross-Inlining Binary Function Similarity Detection

注&#xff1a;在阅读该论文时顺便参考了作者团队的分享视频&#xff1a;【ICSE 2024论文预讲会-第二期-下午-哔哩哔哩】 https://b23.tv/XUVAPy3 在这个视频的末尾最后一个 一.introducion 计算下面两个函数的相似度&#xff1a; 查询函数&#xff1a;脆弱函数&#xff0c;重…
阅读更多...
C++:哈希拓展-位图

C++:哈希拓展-位图

目录 一.问题导入 二.什么是位图? 2.1如何确定目标数在哪个比特位? 2.2如何存放高低位 2.3位图模拟代码实现 2.3.1如何标记一个数 2.3.2如何重置标记 2.3.3如何检查一个数是否被标记 整体代码实现 标准库的Bitset 库中的bitset的缺陷 简单应用 一.问题导入 这道…
阅读更多...
GCP : Memcache backed by Cloud Datastore

GCP : Memcache backed by Cloud Datastore

Memcache backed by Cloud Datastore 的用途主要体现在以下几个方面&#xff1a; 提高性能和可扩展性&#xff1a; Memcache 是一个高性能的分布式内存对象缓存系统&#xff0c;通常用于缓存数据库查询等操作&#xff0c;以减轻数据库负载&#xff0c;加快动态Web应用的响应速度…
阅读更多...
【Python】问题解决：yaml文件加载得到字符串而不是字典

【Python】问题解决：yaml文件加载得到字符串而不是字典

问题描述 最近需要使用python处理yaml文件&#xff0c;但使用过程中发现只能输出字符串的格式&#xff0c;而不是想要的字典格式。 基本使用 在python中想要读写yaml文件&#xff0c;可以安装使用第三方包pyyaml来实现&#xff0c;首先安装一下&#xff1a; pip install pyya…
阅读更多...
时钟之Canvas+JS版

时钟之Canvas+JS版

写在前面 上一篇介绍使用CSSJS方式实现&#xff0c;但元素太过单一。此篇将以HTML5的canvas标签结合JS来实现。 HTML代码 <canvas id"clock" width"300" height"300"></canvas> JS代码 var canvas null; var ctx null; var int…
阅读更多...
最新文章

Copyright @ 2022~2023