1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68
| import mysql.connector
db=mysql.connector.connect( host='192.168.10.125', user='root', password='root', database='test_db' )
cursor=db.cursor()
def insert_data(user,name): sql = "INSERT INTO users(name,age) VALUES(%s,%s)" var=(user,name) cursor.execute(sql,var) db.commit() print(f"insert {cursor.rowcount} records")
def fetch_users(): cursor.execute("SELECT * FROM users") result=cursor.fetchall() for row in result: print(row)
def update_user(user_id,name,age): sql="UPDATE users SET name=%s,age=%s WHERE id=%s" var=(name,age,user_id) cursor.execute(sql,var) db.commit() print(f"Updated {cursor.rowcount} records")
def delete_user(user_id): sql='DELETE FROM users where id=%s' var=(user_id,) cursor.execute(sql,var) db.commit() print(f"Deleted {cursor.rowcount} records")
if __name__ == '__main__': print("增加两条数据:名称Alice,年龄19;名称Bob,年龄18") insert_data("Alice",19) insert_data("Bob",18)
print("查询表数据") fetch_users()
print("更新数据") update_user(1,"Alice_2",20)
print("再次查询表数据") fetch_users()
print("删除两条数据") delete_user(1) delete_user(2)
print("关闭连接") cursor.close() db.close()
|