import pymysql

# 1.创建连接对象
connection = pymysql.connect(host='localhost',
                             user='root',
                             password='123456',
                             database='subjects_kg',
                             port=3306,
                             charset='utf8')
print("connection-->", connection)
# 2.获得cursor（游标）
cursor = connection.cursor()
# 3.执行SQL语句
# create table t1(
# id int primary key auto_increment,
# name varchar(20)
# )
# result = cursor.execute("insert into t1 values(null, 'zhangwuji')")
result = cursor.execute("select * from t1")
# result = cursor.execute("select * from t1 where id = 2")
# TODO pymysql模块，默认开启了事务，所以必须提交后才会生效。
# 提交事务
connection.commit()

# 4.输出结果
print("result-->", result)
# 获取查询的结果
results = cursor.fetchall()
# results = cursor.fetchone()
print("result-->", results)
# for row in results:
#     print(row)

# 5.关闭cursor
cursor.close()

# 6.关闭连接对象
connection.close()