python
import pymysql
from pymysqlpool import ConnectionPool
pool = ConnectionPool(
host='localhost',
user='username',
password='password',
database='database_name',
port=3306
)
conn = pool.get_connection()
with conn.cursor() as cursor:
cursor.execute("SELECT * FROM table_name")
result = cursor.fetchall()
print(result)
conn.close()
sql
CREATE INDEX index_name ON table_name (column_name)
python
import pymysql
data = [('name1', 20), ('name2', 25), ('name3', 30)]
query = "INSERT INTO table_name (name, age) VALUES (%s, %s)"
with pymysql.connect(host='localhost', user='username', password='password', database='database_name') as conn:
with conn.cursor() as cursor:
cursor.executemany(query, data)
conn.commit()
updates = [('John', 1), ('Jane', 2), ('Alice', 3)]
query = "UPDATE table_name SET name=%s WHERE id=%s"
with pymysql.connect(host='localhost', user='username', password='password', database='database_name') as conn:
with conn.cursor() as cursor:
cursor.executemany(query, updates)
conn.commit()
python
import pymysql
with pymysql.connect(host='localhost', user='username', password='password', database='database_name') as conn:
with conn.cursor() as cursor:
try:
conn.begin()
cursor.execute("INSERT INTO table_name (name, age) VALUES ('John', 20)")
cursor.execute("UPDATE table_name SET age = 25 WHERE name = 'John'")
conn.commit()
except Exception as e:
conn.rollback()
print("Transaction rolled back:", str(e))
