用例图

image.png
image.png
image.pngimage.pngimage.pngimage.png
image.pngimage.png

  1. import mysql.connector
  3. connect = {
  4.     "host": "localhost",
  5.     "port": "3306",
  6.     "user": "test",
  7.     "password": "test",
  8.     "database": "vega"
  9. }
  11. with mysql.connector.connect(**connect):
  12.     pass

image.pngimage.png

  1. import mysql.connector
  3. config = {
  4.     "host": "localhost",
  5.     "port": 3306,
  6.     "user": "test",
  7.     "password": "test",
  8.     "database": "vega"
  9. }
  11. with mysql.connector.connect(**config) as connect:
  12.     cursor = connect.cursor()
  13.     sql = "select username, password, email, role_id from t_user"
  14.     cursor.execute(sql)
  15.     for message in cursor:
  16.         print(message)
  17.     pass

image.pngimage.pngimage.pngimage.pngimage.png

  1. import mysql.connector
  3. config = {
  4.     "host": "localhost",
  5.     "port": 3306,
  6.     "user": "test",
  7.     "password": "test",
  8.     "database": "vega"
  9. }
  11. with mysql.connector.connect(**config) as connect:
  12.     username = "1 or 1=1"
  13.     password = "1 or 1=1"
  14.     sql = "select count(1) from t_user where username = %s and password = %s"
  15.     cursor = connect.cursor()
  16.     cursor.execute(sql, (username, password))
  17.     for message in cursor:
  18.         print(message)
  19.     pass

image.png

  1. import mysql.connector
  3. config = {
  4.     "host": "localhost",
  5.     "port": 3306,
  6.     "user": "test",
  7.     "password": "test",
  8.     "database": "vega"
  9. }
  11. try:
  12.     with mysql.connector.connect(**config) as connect:
  13.         sql = "insert into t_user(username, password, email, role_id) values(%s, HEX(AES_ENCRYPT(%s,'turbo')), %s, %s)"
  14.         connect.start_transaction()
  15.         cursor = connect.cursor()
  16.         cursor.execute(sql, ("jack", "jack", "jack@163.com", 2))
  17.         connect.commit()
  18.         pass
  19. except Exception as e:
  20.     if "connect" in dir():
  21.         connect.rollback()
  22.     print(e)

image.pngimage.pngimage.png

  1. import mysql.connector.pooling as pooling
  3. config = {
  4.     "host": "localhost",
  5.     "port": 3306,
  6.     "user": "test",
  7.     "password": "test",
  8.     "database": "vega"
  9. }
  11. try:
  12.     pool = pooling.MySQLConnectionPool(**config, pool_size=10)
  13.     conn = pool.get_connection()
  14.     conn.start_transaction()
  15.     cursor = conn.cursor()
  16.     sql = "update t_user set role_id = %s where id = %s"
  17.     cursor.execute(sql, (1, 5))
  18.     conn.commit()
  19. except Exception:
  20.     if "conn" in dir():
  21.         conn.rollback()
  22.     print(e)
  1. import mysql.connector.pooling as pooling
  3. config = {
  4.     "host": "localhost",
  5.     "port": 3306,
  6.     "user": "test",
  7.     "password": "test",
  8.     "database": "vega"
  9. }
  11. try:
  12.     pool = pooling.MySQLConnectionPool(**config, pool_size=5)
  13.     conn = pool.get_connection()
  14.     conn.start_transaction()
  15.     cursor = conn.cursor()
  16.     sql = "delete from t_user where id = %s"
  17.     cursor.execute(sql, (5,))
  18.     conn.commit()
  19. except Exception as e:
  20.     print(e)

image.png

  1. import mysql.connector.pooling as pooling
  3. config = {
  4.     "host": "localhost",
  5.     "port": 3306,
  6.     "user": "test",
  7.     "password": "test",
  8.     "database": "vega"
  9. }
  11. try:
  12.     pool = pooling.MySQLConnectionPool(**config, pool_size=3)
  13.     conn = pool.get_connection()
  14.     conn.start_transaction()
  15.     cursor = conn.cursor()
  16.     sql = "INSERT INTO t_user(USERNAME, PASSWORD, EMAIL, ROLE_ID) VALUES(%s, HEX(AES_ENCRYPT(%s,'trubo')), %s, %s)"
  17.     value = [
  18.         ["jack", "jack", "jack@163.com", 2],
  19.         ["tom", "tom", "tom@163.com", 2],
  20.         ["jerry", "jerry", "jerry@163.com", 2]
  21.     ]
  22.     cursor.executemany(sql, value)
  23.     conn.commit()
  24. except Exception as e:
  25.     print(e)
  26.     pass