1
pip install pymysql

1
2
3
4
5
import pymysql
class DBConnect:
    def db_connect(DATABASE_URL):
        conn = pymysql.connect(host=host, port=port, user=user, passwd=password, db=db, charset=charset)
        cursor = conn.cursor()

1
2
3
# create table
sql = "create table if not exists mobile(name varchar(128) primary key, moblie_id varchar(128), moblie_name varchar(128), moblie_price varchar(128))"
cursor.execute(sql)

1
2
3
4
5
6
7
# Insert one record
sql = "insert into user(name, password) values ('%s', %s)" % ("张三", "bb")
try:
    cursor.execute(sql)
    conn.commit()
except Exception as e:
    print(e)

1
2
3
4
5
6
7
8
# Insert a number of records
sql = "insert into user(name, moblie_id) values (%s, %s)"
val = (("李四", "cc"), ("王五", "dd"), ("洪六", "ee"))
try:
    cursor.executemany(sql, val)
    conn.commit()
except Exception as e:
    print(e)

1
2
3
4
5
6
7
# Database query
sql = "select * from mobile"
try:
    cursor.execute(sql)
    conn.commit()
except Exception as e:
    print(e)

1
2
3
4
5
6
7
# Database delete
sql = "delete from "tablename" where "columnname" OPERATOR "value" [and|or "column" OPERATOR "value"]"
try:
    cursor.execute(sql)
    conn.commit()
except Exception as e:
    print(e)

1
2
3
4
5
6
7
# Database update
sql = "update t_test t  set t.password = '***'  where t.bs = 2"
try:
    cursor.execute(sql)
    conn.commit()
except Exception as e:
    print(e)

1
cursor = conn.cursor(pymysql.cursors.DictCursor)