python连接数据库并执行SQL语句

第一次发表博客,如果有什么错误请见谅

• 1.创建与数据库连接对象
• 2.建立游标对象
• 3.利用游标对象 执行SQL语句命令
• 4.#提交到数据库
• 5.关闭游标对象
• 6.关闭数据库连接
• 7.建立一个Mysqlpython 类 实现数据库的连接 关闭 和执行SQL语句操作,实现对数据库连接的封装

个人理解

因为在所有计算机语言中, 连接数据库是必不可少的. 所以我们需要学会怎么用python语句去实现连接数据库, 并对数据库进行操作。 因为也是在学习所以也算是记录自己的点滴

连接数据库的操作 分为 以上我列出的几步， 第一步 也是最重要的就是连接上你的数据库。连接上你的数据库你就需要知道一些你数据库的信息。例如: 你计算机的主机号 权限用户名 密码 端口号等

以下列举我本机的一些需要用到的信息

代码块

import pymysql  #1.创建与数据库连接对象 db =pymysql.connect(host="localhost",user="root",                    password="123456",database="db4",                    charset="utf8")  #2.利用db方法创建游标对象 cur = db.cursor()  #3.利用游标对象execute()方法执行SQL命令 #cur.execute(";") #这里填写正确的SQL语句  例如: cur.execute("insert into sheng values\             (16,300000,'台湾省');") #4.提交到数据库执行 db.commit() print("OK") #5.关闭游标对象 cur.close()  #6.断开数据库连接 db.close() 

也可以将自己打的连接关闭数据库 封装成一个类，这样以后就更方便使用了

from pymysql import * class Mysqlpython:     def __init__(self,database,host="localhost",user="root",                  password="123456",port=3306,charset="utf8"):         self.host=host         self.user=user         self.password=password         self.port=port         self.database=database         self.charset=charset #数据库连接方法:       def open(self):         self.db=connect(host=self.host,user=self.user,                         password=self.password,port=self.port,                         database=self.database,                         charset=self.charset) #游标对象         self.cur=self.db.cursor() #数据库关闭方法:     def close(self):         self.cur.close()         self.db.close() #数据库执行操作方法:     def zhixing(self,sql,L=[]):         try:             self.open()             self.cur.execute(sql,L)             self.db.commit()             print("ok")         except Exception as e:             self.db.rollback()             print("Failed",e)         self.close() #数据库查询所有操作方法:         def all(self,sql,L=[]):         try:             self.open()             self.cur.execute(sql,L)             result=self.cur.fetchall()             return result         except Exception as e:             print("Failed",e)         self.close() 

这样的话 就可以在别的地方直接导入就可以使用了 （from …. import…)
最后千万别忘了关闭数据库连接哦 ~