pymysql_connect_insert_parameterized_query_quickstart.py

1import pymysql.cursors
2
3# Connect to the database
4connection = pymysql.connect(host='localhost',
5                             user='user',
6                             password='password',
7                             database='db',
8                             charset='utf8mb4',
9                             cursorclass=pymysql.cursors.DictCursor)
10
11try:
12    with connection.cursor() as cursor:
13        # Create a new record
14        sql = "INSERT INTO `users` (`email`, `password`) VALUES (%s, %s)"
15        cursor.execute(sql, ('webmaster@python.org', 'very-secret'))
16
17    # connection is not autocommit by default. So you must commit to save
18    # your changes.
19    connection.commit()
20
21    with connection.cursor() as cursor:
22        # Read a single record
23        sql = "SELECT `id`, `password` FROM `users` WHERE `email`=%s"
24        cursor.execute(sql, ('webmaster@python.org',))
25        result = cursor.fetchone()
26        print(result)
27finally:
28    connection.close()