CREATE TABLE trademarks (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
registration_number VARCHAR(50) UNIQUE,
applicant VARCHAR(255),
category VARCHAR(100),
status ENUM('已注册', '申请中', '无效') DEFAULT '申请中'
);
import mysql.connector
# 连接数据库
conn = mysql.connector.connect(
host="localhost",
user="root",
password="your_password",
database="trademark_db"
)
cursor = conn.cursor()
# 插入商标信息
sql = "INSERT INTO trademarks (name, registration_number, applicant, category, status) VALUES (%s, %s, %s, %s, %s)"
values = ("泉州制造", "TM2024123456789", "泉州科技有限公司", "第35类", "已注册")
cursor.execute(sql, values)
# 提交事务
conn.commit()
print("商标信息已成功插入！")
# 关闭连接
cursor.close()
conn.close()
# 查询商标信息
sql = "SELECT * FROM trademarks WHERE applicant = %s"
values = ("泉州科技有限公司",)
cursor.execute(sql, values)
results = cursor.fetchall()
for row in results:
print(row)
from flask import Flask, jsonify
import mysql.connector
app = Flask(__name__)
def get_trademarks():
conn = mysql.connector.connect(
host="localhost",
user="root",
password="your_password",
database="trademark_db"
)
cursor = conn.cursor()
cursor.execute("SELECT * FROM trademarks")
results = cursor.fetchall()
cursor.close()
conn.close()
return results
@app.route('/trademarks', methods=['GET'])
def get_all_trademarks():
trademarks = get_trademarks()
return jsonify([dict(zip(('id', 'name', 'registration_number', 'applicant', 'category', 'status'), row)) for row in trademarks])
if __name__ == '__main__':
app.run(debug=True)
@app.route('/search', methods=['GET'])
def search_trademarks():
query = request.args.get('query')
if not query:
return jsonify({"error": "缺少查询参数"}), 400
conn = mysql.connector.connect(
host="localhost",
user="root",
password="your_password",
database="trademark_db"
)
cursor = conn.cursor()
sql = "SELECT * FROM trademarks WHERE name LIKE %s OR registration_number LIKE %s"
values = (f"%{query}%", f"%{query}%")
cursor.execute(sql, values)
results = cursor.fetchall()
cursor.close()
conn.close()
return jsonify([dict(zip(('id', 'name', 'registration_number', 'applicant', 'category', 'status'), row)) for row in results])
@app.route('/trademarks/
def update_trademark(id):
data = request.json
new_status = data.get('status')
if not new_status:
return jsonify({"error": "缺少状态参数"}), 400
conn = mysql.connector.connect(
host="localhost",
user="root",
password="your_password",
database="trademark_db"
)
cursor = conn.cursor()
sql = "UPDATE trademarks SET status = %s WHERE id = %s"
values = (new_status, id)
cursor.execute(sql, values)
conn.commit()
cursor.close()
conn.close()
return jsonify({"message": "商标状态已更新"})
@app.route('/trademarks/
def delete_trademark(id):
conn = mysql.connector.connect(
host="localhost",
user="root",
password="your_password",
database="trademark_db"
)
cursor = conn.cursor()
sql = "DELETE FROM trademarks WHERE id = %s"
values = (id,)
cursor.execute(sql, values)
conn.commit()
cursor.close()
conn.close()
return jsonify({"message": "商标信息已删除"})