MySQL 数据库基础

# 启动 MySQL 服务
net start mysql

# 关闭 MySQL 服务
net stop mysql

# 登录 MySQL
mysql -u root -p

-- 创建数据库
CREATE DATABASE mydb;

-- 选择/使用数据库
USE mydb;

-- 查看所有数据库
SHOW DATABASES;

-- 删除数据库（⚠️ 不可恢复！）
DROP DATABASE mydb;

CREATE TABLE tb_users (
    id        INT          PRIMARY KEY  AUTO_INCREMENT,
    username  VARCHAR(50)  NOT NULL,
    email     VARCHAR(100),
    age       TINYINT      DEFAULT 0,
    createtime DATETIME    DEFAULT CURRENT_TIMESTAMP
);

-- ① 增（INSERT）：插入一条记录
INSERT INTO tb_users (username, email, age)
VALUES ('张三', 'zhangsan@email.com', 22);

-- ② 查（SELECT）：查询所有记录
SELECT * FROM tb_users;

-- 查询特定条件
SELECT username, age FROM tb_users WHERE age > 20;

-- ③ 改（UPDATE）：修改记录
UPDATE tb_users SET age = 23 WHERE username = '张三';

-- ④ 删（DELETE）：删除记录
DELETE FROM tb_users WHERE id = 1;

pip install pymysql

import pymysql

# 建立数据库连接
db = pymysql.connect(
    host='localhost',      # 数据库地址
    user='root',           # 用户名
    password='123456',     # 密码
    database='mydb',       # 数据库名
    charset='utf8mb4'      # 字符编码（推荐utf8mb4）
)

# 获取游标对象
cursor = db.cursor()

# 方式1：直接拼接（⚠️ 有SQL注入风险，仅学习用）
sql = "INSERT INTO books (name, price) VALUES ('Python入门', 59.9)"
cursor.execute(sql)

# 方式2：参数化查询（✅ 推荐！安全防注入）
sql = "INSERT INTO books (name, price) VALUES (%s, %s)"
cursor.execute(sql, ('Flask实战', 69.8))

# 批量插入
data = [
    ('Django教程', 79.0),
    ('MySQL必知必会', 49.5),
    ('数据分析实战', 89.0)
]
cursor.executemany(sql, data)

db.commit()  # ⚠️ 别忘了提交！

# 查询所有记录
cursor.execute("SELECT * FROM books")
results = cursor.fetchall()

for row in results:
    print(f"书名: {row[1]}, 价格: {row[2]}")

# 查询单条记录
cursor.execute("SELECT * FROM books WHERE id = %s", (1,))
book = cursor.fetchone()
print(book)  # 返回元组: (1, 'Python入门', 59.9)

# 条件查询
cursor.execute("SELECT name, price FROM books WHERE price > %s", (60,))
expensive = cursor.fetchall()

sql = "UPDATE books SET price = %s WHERE name = %s"
cursor.execute(sql, (55.0, 'Python入门'))
db.commit()

print(f"受影响的行数: {cursor.rowcount}")

sql = "DELETE FROM books WHERE id = %s"
cursor.execute(sql, (3,))
db.commit()

import pymysql

db = pymysql.connect(
    host='localhost', user='root',
    password='123456', database='mydb',
    charset='utf8mb4'
)

try:
    cursor = db.cursor()
    
    # 执行你的 SQL 操作
    cursor.execute("INSERT INTO books (name, price) VALUES (%s, %s)",
                   ('新书', 99.0))
    
    db.commit()       # 成功则提交
    print("操作成功！")

except Exception as e:
    db.rollback()     # 出错则回滚，撤销所有更改
    print(f"操作失败: {e}")

finally:
    cursor.close()    # 关闭游标
    db.close()        # 关闭连接

# 传统 SQL 写法
cursor.execute("INSERT INTO users (name, age) VALUES ('李四', 25)")

# ORM 写法 —— 像操作普通 Python 对象一样！
user = User(name='李四', age=25)
session.add(user)
session.commit()