江苏龙网

  1. 主页 > 生活百科 > >

10分钟教你Python+MySQL数据库操作( 二 )

Python+MySQL


import mysql.connector
如果没有产生错误，则表明安装成功 。
3.2 创建数据库连接
这里连接的是我之前创建的blank这个user 。如果数据库已经存在的话，我们可以直接连接;如果数据库不存在，直接连接则会报错，这个时候我们就需要创建一个数据库，创建数据库可以在MySQL Workbench中创建，也可以在python中使用"CREATE DATABASE"语句，在本实验中，我们使用已经在MySQL workbench中已经建好的test_s这个数据库 。
import mysql.connector #连接数据库 config = { 'user' : 'blank' #用户名 'password' : 'password' #自己设定的密码 'host' : '127.0.0.1' #ip地址，本地填127.0.0.1，也可以填localhost 'port' : '3306' #端口，本地的一般为3306 'database' : 'test_s' #数据库名字，这里选用test_s } con = mysq;.connector.connect(**config)3.3 创建数据表STEP1:当Python 和数据之间的连接建立起来之后，要操作数据库，就需要让 Python对数据库执行SQL语句 。创建数据表我们使用"CREATE TABLE"语句，在test_s这个数据库中创建一个叫做customers的表格，其中包含id、name、address、sex、age、sl这六个columns 。Python是通过游标执行SQL语句的，所以，连接建立之后，就要利用连接对象得到游标对象 。
cursor():表示游标
execute():是执行语句
STEP2****:一般在创建新表的时候，我们还会设置一个主键(PRIMARY KEY)来方便进行查询工作 。创建主键，我们可以用"INT AUTO_INCREMENT PRIMARY KEY"#创建一个表 # buffered = True 不设的话，查询结果没有读完会报错 # raise errors.InternalError("Unread result found") mycursor = con.cursor(buffered = True) mycursor.execute("CREATE TABLE customers(id INT AUTO_INCREMENT PRIMARY KEY,name VARCHAR(255) , address VARCHAR(255),7sex VARCHAR(225) , age INT(10) , sl INT(10))")
VARCHAR()表示的是数据类型，定义的是变长字符串;INT()表示整型
STEP3:执行语句 。执行完后，我们可以回到MySQL workbench，可以看到在test_s下面的customers这个表格，其中Columns为我们创建的id，name，address，sex，age和sl 。STEP4:但是，当我们再次执行语句的时候，由于已经创建了"customers"这个表，所以再次执行会报错，这个时候就需要加一个判断，判断这个表是否已经存在于test_s这个数据库中ProgrammingError: Table 'customers' alreadyy exists STEP5****:我们可以用"SHOW TABLES"语句来查看数据表是否已经存在，如果存在就print"table already exists",如果不存在，就print"table does not exist" 。def tableExists(mycursor, name): stmt = "SHOW TABLES LIKE '" +name+ "'" mycursor.execute(stmt) return mycursor.fetchone() mycursor = con.cursor() if tableExists(mycursor , 'customers'): print("table already exists") else: print("table not exists")STEP6:上面的语句只是为了帮助我们判断是否有同名表，当我们要新建一个表时，我们可以在这个判断的基础上，在创建新表前删掉数据库内的同名表，再建新表 。删除我们用的是"DROP TABLE"，新建表是"CERATE TABLE"import mysql.connector #连接数据库 config = { 'user' : 'blank', 'password' :'fuying123888', 'host' : '127.0.0.1', 'port':'3306', 'database' : 'test_s' } con = mysql.connector.connect(**config) # 检查一个表是否存在 def tableExists(mycursor, name): stmt = "SHOW TABLES LIKE '"+name+"'" mycursor.execute(stmt) return mycursor.fetchone() # 删除一个表(无论它是否已经存在) def dropTable(mycursor, name): stmt = "DROP TABLE IF EXISTS "+name mycursor.execute(stmt) # buffered=True 不设的话，查询结果没有读完会报错 # raise errors.InternalError("Unread result found") mycursor = con.cursor(buffered=True) # 删除临时表 tableName = 'customers' dropTable(mycursor, tableName) # 创建一个表 mycursor.execute("CREATE TABLE customers(id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), address VARCHAR(255),sex VARCHAR(225), age INT(10), sl INT(10))")3.4 增、改、删、查3.4.1 增
在cutomers表中插入数据用的是"INSERT INTO"语句 。
除了用一条条用execute( )插入之外，我们还可以用executemany()的方式批量插入，也就是val中包含的是一个元组列表，包含我们想要插入的数据 。
需要注意的事是:如果数据表格有更新，那么必须用到commit()语句，否则在workbench是看不到插入的数据的 。
#往表里插入一些记录 sql="INSERT INTO customers(name,address,sex,age,sl) VALUES(%s, %s,%s,%s,%s)" val = ("John", "Highway 21","M",23,5000) mycursor.execute(sql, val) val = ("Jenny", "Highway 29","F",30,12500) mycursor.execute(sql, val) val=[("Tom","ABC 35","M",35,14000), ("Tom1","Highway 29","M",28,6700), ("Lily","Road 11","F",30,8000), ("Martin","Road 24","M",35,14000), ("Sally","Fast 56","M",32,15000)] mycursor.executemany(sql, val) con.commit()


推荐阅读


上一篇：黄小茶功效禁忌,黄茶的功效与作用及禁忌详解

下一篇：沩山毛尖冲泡方法,沩山毛尖有什么历史渊源