我要评论前言
要实现一个简单的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 bcrypt
app = 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.json
username = 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!'}), 201
except pymysql.integrityerror:
return jsonify({'message': 'username already exists!'}), 400
finally:
cursor.close()
conn.close()
@app.route('/login', methods=['post'])
def login():
data = request.json
username = 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!'}), 200
else:
return jsonify({'message': 'incorrect username or password!'}), 401
finally:
cursor.close()
conn.close()
@app.route('/send_message', methods=['post'])
def send_message():
data = request.json
sender = 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), 200
if __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、添加身份验证令牌等。
到此这篇关于python3访问mysql数据库的实现步骤的文章就介绍到这了,更多相关python3访问mysql内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论