pycharm和数据库链接

数据库连接

pycharm 社区版链接mysql数据库

Pycharm社区版连接数据库

解决pycharm连接mysql报错（DB Navigator-Connection error）

Error: 1045

学习

python3基础：操作mysql数据库

Python3 MySQL 数据库连接 - PyMySQL 驱动-菜鸟教程

Python异常处理及常见报错解决

# 函数介绍
pymysql.connect() #连接数据库函数
conn.cursor() #获取游标
#创建pythonBD数据库
cursor.execute('CREATE DATABASE IF NOT EXISTS pythonDB;')
cursor.close()#先关闭游标
conn.close()#再关闭数据库连接
#创建user表
cursor.execute('DROP TABLE IF EXISTS EMPLOYEE;')
sql= """CREATE TABLE EMPLOYEE(
        FIRST_NAME  CHAR(20)    NOT NULL,
        LAST_NAME   CHAR(20)    ，
        PRIMARY KEY (FIRST_NAME)
        )"""
cursor.execute(sql)
#取一条数据
res=cur.fetchone()
cursor.fetchone() #获取游标所在处的一行数据，返回元组，没有返回None
cursor.fetchmany(size) #接受size行返回结果行。如果size大于返回的结果行的数量，则会返回cursor.arraysize条数据。
cursor. fetchall() #接收全部的返回结果行。
rowcount #这是一个只读属性，并返回执行execute()方法后影响的行数。

# 创建数据库
import pymysql
#打开数据库连接
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", database="shop", charset="utf8")
#获取游标 即使用cursor()方法创建一个游标对象 cursor
cursor=conn.cursor()
#创建pythonDB数据库
cursor.execute('CREATE DATABASE IF NOT EXISTS pythonDB;')
cursor.close()#先关闭游标
conn.close()#再关闭数据库连接
print('创建pythonBD数据库成功')

# 创建数据表
import pymysql
#打开数据库连接
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", database="pythonDB", charset="utf8")
#获取游标
cursor=conn.cursor()
print(cursor)

#创建user表
cursor.execute('DROP TABLE IF EXISTS EMPLOYEE;')
sql= """CREATE TABLE EMPLOYEE(
        FIRST_NAME  CHAR(20)    NOT NULL,
        LAST_NAME   CHAR(20)    ,
        AGE         INT,
        SEX         CHAR(1),
        INCOME      FLOAT,
        PRIMARY KEY (FIRST_NAME)
        )"""

cursor.execute(sql)
cursor.close()#先关闭游标
conn.close()#再关闭数据库连接
print('创建数据表成功')
#插入多条数据
insert=cur.executemany(sql,[('Harry','Potter',17,'M',8000),('Hermione','Granger',17,'F',7000),('Ron','Weasle',17,'M',6000)])

# 插入单条数据
'''插入单条数据'''
import pymysql
#打开数据库连接
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')

cursor=conn.cursor()#获取游标

insert=cursor.execute("insert into employee values('Mac','Mohan',20,'M',2000)")
print('添加语句受影响的行数：',insert)

#方法二
sql = """INSERT INTO EMPLOYEE
        VALUES('Guilan', 'Chen', 21, 'F', 9998)"""
try:
    #执行sql语句
    cursor.execute(sql)
    #提交到数据库执行
    conn.commit()
    print('sql执行成功')
except:
    #如果发生错误则回滚
    conn.rollback()

#另一种插入数据的方式，通过字符串传入值
sql="INSERT INTO EMPLOYEE VALUES(%s,%s,%s,%s,%s)"
cursor.execute(sql,('Xin','Zhao',21,'F',9997))

cursor.close()#先关闭游标
conn.close()#再关闭数据库连接

# 插入多条数据
'''插入多条数据'''
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#另一种插入数据的方式，通过字符传入值
sql = "INSERT INTO EMPLOYEE VALUES (%s,%s,%s,%s,%s)"
insert=cur.executemany(sql,[('Harry','Potter',17,'M',8000),('Hermione','Granger',17,'F',7000),('Ron','Weasle',17,'M',6000)])
print('批量插入返回受影响的行数：',insert)
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

# 取一条数据
'''fetchone'''
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

cur.execute("SELECT * FROM EMPLOYEE;")
while 1:
    res=cur.fetchone()
    if res is None:
        #表示已经取完结果集
        break
    print(res)
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

# 取多条数据
'''fetchmany'''
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

cur.execute("SELECT * FROM EMPLOYEE;")
#取3条数据
resTuple=cur.fetchmany(3)
print(type(resTuple))
for res in resTuple:
    print(res)
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

# 取所有数据（该代码并不输出所有数据）
'''fetchall'''
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

cur.execute("SELECT * FROM EMPLOYEE;")
#取所有数据
resTuple=cur.fetchall()
print(type(resTuple))
print('共%d条数据'%len(resTuple))

cur.close()
conn.commit()
conn.close()
print('sql执行成功')

# 条件查询
'''fetchall'''
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE WHERE INCOME > %s" % (9000)
try:
    #执行SQL语句
    cur.execute(sql)
    #获取所有记录列表
    results = cur.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 fetch data")

# 关闭数据库连接
cur.close()
#conn.commit()
conn.close()
print('sql执行成功')

# 更新多条数据
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#更新前查询所有数据
cur.execute("SELECT * FROM EMPLOYEE WHERE FIRST_NAME IN ('Qingyang','Guilan');")
print('更新前的数据为：')
for res in cur.fetchall():
    print(res)

print('*'*40)
#更新2条数据
sql="UPDATE EMPLOYEE SET AGE= %s WHERE FIRST_NAME=%s"
update=cur.executemany(sql,[(3,'Qingyang'),(5,'Guilan')])

#更新2条数据后查询所有数据
cur.execute("SELECT * FROM EMPLOYEE WHERE FIRST_NAME IN ('Qingyang','Guilan');")
print('更新后的数据为：')
for res in  cur.fetchall():
    print(res)

cur.close()
conn.commit()
conn.close()
print('sql执行成功')

# 还是更新
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

print('*'*40)
#SQL更新语句
sql="UPDATE EMPLOYEE SET AGE=AGE+1 WHERE SEX='%c'" %('M')
try:
    #执行SQL语句
    cur.execute(sql)
    #提交到数据库执行
    conn.commit()
except:
    #发生错误时回滚
    conn.rollback()


cur.close()
conn.commit()
conn.close()
print('sql执行成功')

# 删除
'''fetchall'''
import pymysql
#打开数据库连接，不指定数据库
conn = pymysql.connect(host="localhost", user="root", password="abcd1234", charset="utf8")
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#删除前查询所有数据
cur.execute("SELECT * FROM EMPLOYEE;")
print('删除前的数据为：')
for res in  cur.fetchall():
    print(res)

print('*'*40)
#删除1条数据
cur.execute("DELETE FROM EMPLOYEE WHERE age=3")
#删除多条数据
sql= "DELETE FROM EMPLOYEE WHERE age=%s"
cur.executemany(sql,[(4),(5)])


#删除后查询所有数据
cur.execute("SELECT * FROM EMPLOYEE;")
print('删除前的数据为：')
for res in  cur.fetchall():
    print(res)

cur.close()
conn.commit()
conn.close()
print('sql执行成功')

# 回滚事务
# 回滚事务
conn.rollback()
cur.execute("SELECT * from EMPLOYEE;")
print('回滚事务后的数据为:')
for res in cur.fetchall():
    print(res)