import pymysql #导入相应的模块
try:
db = pymysql.connect("localhost","root", "123456", "tao")
print("连接成功")
except:
print("连接失败")
cursor = db.cursor() #创建一个游标对象
cursor.execute("SELECT VERSION()") #使用execute()方法 执行sql 语句
rs = cursor.fetchone() # 使用fetchone 获取单条数据
print(rs)
cursor.execute("SELECT * FROM test2")
rs = cursor.fetchone()
print(rs)
db.close() #关闭数据库
import pymysql
def getConnection(h, u, p, d):
db = pymysql.connect(h, u, p, d)
return db
if __name__ == "__main__":
db = getConnection("localhost", "root", "123456", "tao")
cursor = db.cursor() # 通过cursor方法 获取一个游标对象
cursor.execute("DROP TABLE IF EXISTS test3")
sql = """CREATE TABLE test3( FIRST_NAME CHAR(20) NOT NULL, LAST_NAME CHAR(20) NOT NULL, AGE INT, SEX CHAR(1), INCOME FLOAT )"""
cursor.execute(sql)
sql = """INSERT INTO test3 VALUES('mac', 'mohan', 20, 'M', 2000)"""
cursor.execute(sql) #执行sql语句
db.commit() # 提交到数据库执行
db.close()
还没有评论,来说两句吧...