Python3訪問MySQL數(shù)據(jù)庫的實現(xiàn)步驟
更新時間：2024年11月17日 11:23:48 作者：HBLOG
要實現(xiàn)一個簡單的IM（即時通訊）系統(tǒng),支持用戶注冊、登錄和聊天記錄存儲,你可以使用Python和mysql數(shù)據(jù)庫,以下是一個基本的實現(xiàn)步驟,并通過代碼示例講解的非常詳細(xì),需要的朋友可以參考下
前言
要實現(xiàn)一個簡單的IM（即時通訊）系統(tǒng)，支持用戶注冊、登錄和聊天記錄存儲，你可以使用Python和mysql數(shù)據(jù)庫。以下是一個基本的實現(xiàn)示例： 要使用MySQL創(chuàng)建表并通過Python提供一個API服務(wù)，你可以使用Flask框架來實現(xiàn)API服務(wù)，并使用PyMySQL庫來連接MySQL數(shù)據(jù)庫。以下是一個基本的實現(xiàn)步驟：
1. 安裝所需庫
首先，確保你安裝了Flask和PyMySQL庫：
pip install flask pymysql
2. MySQL數(shù)據(jù)庫設(shè)置
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
假設(shè)你已經(jīng)在MySQL中創(chuàng)建了一個數(shù)據(jù)庫，接下來創(chuàng)建用戶和消息表。
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. 創(chuàng)建Flask API服務(wù)
一個簡單的Flask應(yīng)用，提供注冊、登錄和發(fā)送消息的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服務(wù)
將上述代碼保存為一個Python文件（例如main.py），然后運行：
python main.py
這將啟動一個Flask開發(fā)服務(wù)器，你可以通過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" ] ]
請注意，這個示例是一個基本實現(xiàn)，適用于學(xué)習(xí)和測試。在生產(chǎn)環(huán)境中，你需要考慮更多的安全性和性能優(yōu)化，例如使用HTTPS、添加身份驗證令牌等。
到此這篇關(guān)于Python3訪問MySQL數(shù)據(jù)庫的實現(xiàn)步驟的文章就介紹到這了,更多相關(guān)Python3訪問MySQL內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了Python標(biāo)準(zhǔn)庫與第三方庫,需要的朋友可以參考下2014-07-07
在日常的 Git 使用中,我們通常使用 git clone 命令克隆倉庫,但這默認(rèn)只會下載遠(yuǎn)程倉庫的默認(rèn)分支,下面我們就來看看如何使用Python自動化腳本實現(xiàn)下載 Git 倉庫中的所有分支吧2025-10-10
OpenCV簡單標(biāo)準(zhǔn)數(shù)字識別的完整實例
這篇文章主要給大家介紹了關(guān)于OpenCV簡單標(biāo)準(zhǔn)數(shù)字識別的相關(guān)資料,要通過opencv 進(jìn)行數(shù)字識別離不開訓(xùn)練庫的支持，需要對目標(biāo)圖片進(jìn)行大量的訓(xùn)練，才能做到精準(zhǔn)的識別出目標(biāo)數(shù)字,需要的朋友可以參考下2021-09-09
這篇文章主要介紹了Python如何將日志寫入到數(shù)據(jù)表中的實現(xiàn)方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2026-03-03
這篇文章主要介紹了如何利用python實現(xiàn)蝴蝶曲線，自然界的很多現(xiàn)象都可以適當(dāng)?shù)暮喕么鷶?shù)曲線和超越曲線來表達(dá)，下面我們就來利用去先畫出小蝴蝶，需要的小伙伴可以參考一下2022-03-03
python實現(xiàn)把二維列表變?yōu)橐痪S列表的方法分析
這篇文章主要介紹了python實現(xiàn)把二維列表變?yōu)橐痪S列表的方法,結(jié)合實例形式總結(jié)分析了Python列表推導(dǎo)式、嵌套、循環(huán)等相關(guān)操作技巧,需要的朋友可以參考下2019-10-10
這篇文章主要介紹了Python利用Turtle繪畫簡單圖形，文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價值，需要的朋友可以參考一下2022-07-07
list和str兩種類型數(shù)據(jù)，有不少相似的地方，也有很大的區(qū)別。本講對她們做個簡要比較，同時也是對前面有關(guān)兩者的知識復(fù)習(xí)一下，所謂“溫故而知新”。2014-09-09
Python使用subprocess模塊檢測Linux用戶是否存在
本文介紹了使用Python的subprocess模塊檢測和創(chuàng)建Unix系統(tǒng)用戶的方法,通過調(diào)用id命令判斷用戶是否存在,若不存在則使用adduser命令創(chuàng)建用戶,適用于Ubuntu/Debian系統(tǒng),感興趣的小伙伴可以了解下2026-01-01
本文主要介紹了Python?字符替換的四方法,主要包括replace、translate、maketrans?和正則這是四種方法,具有一定的參考價值,感興趣的可以了解一下2024-01-01