import MySQLdb
#打开数据库链接
lcDB = MySQLdb.connect("127.0.0.1", "%”,"123456","go" )

 1 import MySQLdb
 2 #打开数据库链接
 3 lcDB = MySQLdb.connect("127.0.0.1", "root","123456","test" )
 4 #使用cursor（）方法获取操作游标
 5 cursor = lcDB.cursor()
 6
 7 #使用execute方法执行SQL语句
 8 cursor.execute('select version()') #查询MYSQL版本
 9
10 #使用fetchone()方法获取一条数据
11 data = cursor.fetchone()
12
13 print("Database version : %s"%data)
14
15 #使用 execute（）方法执行SQL，如果表存在则删除
16 cursor.execute("DROP TABLE if exists employee")
17
18 #使用预处理语句创建表
19 sql = """create table employee(
20         first_name char(20) not null,
21         last_name char(20),
22         age int,
23         sex char(1),
24         income float
25         )"""
26
27 cursor.execute(sql)
28
29 #关闭数据库链接
30 lcDB.close()

Database version : 8.0.11

import  pymysql#打开数据库链接
lcDB = pymysql.connect("127.0.0.1", "root", "123456", "test")#使用cursor()方法创建一个游标对象cursor
cursor = lcDB.cursor()#SQL 插入语句
#此处可将SQL换位update, delete等语句
sql = "insert into employee(first_name,\last_name, age, sex, income)\values ('%s', '%s', '%s','%s', '%s')"% \('li', 'Mohan', 20, 'M', 1000)try:# 使用execute()方法执行sql,
    cursor.execute(sql)#提交到数据库执行sql语句　　 lcDB.commit() 

except: 　　#发生错误时回滚 　　lcDB.rollback() 

#关闭数据库 lcDB.close()

import  pymysql#打开数据库链接
lcDB = pymysql.connect("127.0.0.1", "root", "123456", "test")#使用cursor()方法创建一个游标对象cursor
cursor = lcDB.cursor()#SQL 插入语句
#此处可将SQL换位update, delete等语句
sql = "select * from employee where income > %s"%(2000)try:# 使用execute()方法执行sql,
    cursor.execute(sql)#获取所有记录列表results = cursor.fetchall()for row in results:fname = row[0]lname = row[1]age = row[2]sex = row[3]income = row[4]#打印结果print("fname = %s, lname = %s, age = %s, sex = %s,income = %s" % \(fname, lname,age, sex, income))except:print("ERROr: unable to fecth data")#关闭数据库
lcDB.close()

import  pymysql
from sshtunnel import SSHTunnelForwarderserver =  SSHTunnelForwarder(("132.223.3.23", 19), #ssh IP和portssh_password = "123123",#ssh 密码ssh_username = "root",#ssh账号remote_bind_address = ("1.1.1.1", 3306)) #数据库所在的IP和端口

#启动服务
server.start()
#打印本地端口，已检查是否配置正确
print(server.local_bind_host)goDB = pymysql.connect(host = "127.0.0.1", #固定写法port = server.local_bind_port,user = "root", #数据库账号passwd = "2345",#数据库密码db = "指定数据库名字")# 可以限定，只访问特定的数据库,否则需要在mysql的查询或者操作语句中，指定好表名
cur = goDB.cursor()
sql = "select no from gds order by rand() limit 10" #限制每次随机查询10条数据try:#执行SQL语句检查是否连接成功cur.execute("select version()")result = cur.fetchone()print("Database version: %s" % result)cur.execute(sql)data = cur.fetchall()for row in data:good_no = row[0]print(good_no)except:print("Error")#关闭连接
goDB.close()
server.close()