本文目录
- 如何用python创建数据库
- python 怎么创建create mysql的数据库
- python3如何根据csv文件的列的内容，自动建数据库表
- 如何在python中进行数据库的添加
- python专业版本上如何直接创建数据库
- linux环境下python怎样操作mysql数据库
- python怎么与neo4j图数据库连接(neo4j创建数据库)
如何用python创建数据库
首先你得选择一种数据库，比如mysql。然后使用python的mysql库连接mysql，并发送sql语句，实现创建DB的操作。
python 怎么创建create mysql的数据库
我采用的是MySQLdb操作的MYSQL数据库。先来一个简单的例子吧：import MySQLdb try: conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,db=’test’,port=3306) cur=conn.cursor() cur.execute(’select * from user’) cur.close() conn.close()except MySQLdb.Error,e: print "Mysql Error %d: %s" % (e.args) 请注意修改你的数据库，主机名，用户名，密码。下面来大致演示一下插入数据，批量插入数据，更新数据的例子吧：import MySQLdb try: conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,port=3306) cur=conn.cursor() cur.execute(’create database if not exists python’) conn.select_db(’python’) cur.execute(’create table test(id int,info varchar(20))’) value= cur.execute(’insert into test values(%s,%s)’,value) values= for i in range(20): values.append((i,’hi rollen’+str(i))) cur.executemany(’insert into test values(%s,%s)’,values) cur.execute(’update test set info="I am rollen" where id=3’) conn.commit() cur.close() conn.close() except MySQLdb.Error,e: print "Mysql Error %d: %s" % (e.args) 请注意一定要有conn.commit()这句来提交事务，要不然不能真正的插入数据。运行之后我的MySQL数据库的结果就不上图了。import MySQLdb try: conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,port=3306) cur=conn.cursor() conn.select_db(’python’) count=cur.execute(’select * from test’) print ’there has %s rows record’ % count result=cur.fetchone() print result print ’ID: %s info %s’ % result results=cur.fetchmany(5) for r in results: print r print ’==’*10 cur.scroll(0,mode=’absolute’) results=cur.fetchall() for r in results: print rconn.commit() cur.close() conn.close() except MySQLdb.Error,e: print "Mysql Error %d: %s" % (e.args) 运行结果就不贴了，太长了。查询后中文会正确显示，但在数据库中却是乱码的。经过我从网上查找，发现用一个属性有可搞定：在Python代码 conn = MySQLdb.Connect(host=’localhost’, user=’root’, passwd=’root’, db=’python’) 中加一个属性： 改为：conn = MySQLdb.Connect(host=’localhost’, user=’root’, passwd=’root’, db=’python’,charset=’utf8’) charset是要跟你数据库的编码一样，如果是数据库是gb2312 ,则写charset=’gb2312’。 下面贴一下常用的函数：然后,这个连接对象也提供了对事务操作的支持,标准的方法commit() 提交rollback() 回滚cursor用来执行命令的方法:callproc(self, procname, args):用来执行存储过程,接收的参数为存储过程名和参数列表,返回值为受影响的行数execute(self, query, args):执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数executemany(self, query, args):执行单挑sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数nextset(self):移动到下一个结果集cursor用来接收返回值的方法:fetchall(self):接收全部的返回结果行.fetchmany(self, size=None):接收size条返回结果行.如果size的值大于返回的结果行的数量,则会返回cursor.arraysize条数据.fetchone(self):返回一条结果行.scroll(self, value, mode=’relative’):移动指针到某一行.如果mode=’relative’,则表示从当前所在行移动value条,如果 mode=’absolute’,则表示从结果集的第一行移动value条.参考资料：MySQLdb‘s user guidepackage MySQLdb
python3如何根据csv文件的列的内容，自动建数据库表
我这里选“Online Transaction Processing(OLTP)”，自己的服务器，应该够用了，按“Next”继续是否启用TCP/IP连接，设定端口，如果不启用，就只能在自己的机器上访问mysql数 据库了，我这里启用，把前面的勾打上，Port Number：3306，在这个页面上，您还可以选择“启用标准模式”（Enable Strict Mode），这样MySQL就不会允许细小的语法错误。如果您还是个新手，我建议您取消标准模式以减少麻烦。但熟悉MySQL以后，尽量使用标准模式，因 为它可以降低有害数据进入数据库的可能性。按“Next”继续望采纳
如何在python中进行数据库的添加
你可以访问Python数据库接口及API查看详细的支持数据库列表。不同的数据库你需要下载不同的DB API模块，例如你需要访问Oracle数据库和Mysql数据，你需要下载Oracle和MySQL数据库模块。DB-API 是一个规范. 它定义了一系列必须的对象和数据库存取方式, 以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口 。Python的DB-API，为大多数的数据库实现了接口，使用它连接各数据库后，就可以用相同的方式操作各数据库。Python DB-API使用流程：引入 API 模块。获取与数据库的连接。执行SQL语句和存储过程。关闭数据库连接。什么是MySQLdb?MySQLdb 是用于Python链接Mysql数据库的接口，它实现了 Python 数据库 API 规范 V2.0，基于 MySQL C API 上建立的。如何安装MySQLdb?为了用DB-API编写MySQL脚本，必须确保已经安装了MySQL。复制以下代码，并执行：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb如果执行后的输出结果如下所示，意味着你没有安装 MySQLdb 模块：Traceback (most recent call last):File "test.py", line 3, in 《module》import MySQLdbImportError: No module named MySQLdb安装MySQLdb，请访问 ，(Linux平台可以访问：)从这里可选择适合您的平台的安装包，分为预编译的二进制文件和源代码安装包。如果您选择二进制文件发行版本的话，安装过程基本安装提示即可完成。如果从源代码进行安装的话，则需要切换到MySQLdb发行版本的顶级目录，并键入下列命令:$ gunzip MySQL-python-1.2.2.tar.gz$ tar -xvf MySQL-python-1.2.2.tar$ cd MySQL-python-1.2.2$ python setup.py build$ python setup.py install注意：请确保您有root权限来安装上述模块。数据库连接连接数据库前，请先确认以下事项：您已经创建了数据库 TESTDB.在TESTDB数据库中您已经创建了表 EMPLOYEEEMPLOYEE表字段为 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。连接数据库TESTDB使用的用户名为 "testuser" ，密码为 "test123",你可以可以自己设定或者直接使用root用户名及其密码，Mysql数据库用户授权请使用Grant命令。在你的机子上已经安装了 Python MySQLdb 模块。如果您对sql语句不熟悉，可以访问我们的 SQL基础教程实例：以下实例链接Mysql的TESTDB数据库：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb# 打开数据库连接db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# 使用execute方法执行SQL语句cursor.execute("SELECT VERSION()")# 使用 fetchone() 方法获取一条数据库。data = cursor.fetchone()print "Database version : %s " % data# 关闭数据库连接db.close()执行以上脚本输出结果如下：Database version : 5.0.45创建数据库表如果数据库连接存在我们可以使用execute()方法来为数据库创建表，如下所示创建表EMPLOYEE：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb# 打开数据库连接db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# 如果数据表已经存在使用 execute() 方法删除表。cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")# 创建数据表SQL语句sql = """CREATE TABLE EMPLOYEE (FIRST_NAME CHAR(20) NOT NULL,LAST_NAME CHAR(20),AGE INT,SEX CHAR(1),INCOME FLOAT )"""cursor.execute(sql)# 关闭数据库连接db.close()数据库插入操作以下实例使用执行 SQL INSERT 语句向表 EMPLOYEE 插入记录：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb# 打开数据库连接db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 插入语句sql = """INSERT INTO EMPLOYEE(FIRST_NAME,LAST_NAME, AGE, SEX, INCOME)VALUES (’Mac’, ’Mohan’, 20, ’M’, 2000)"""try:# 执行sql语句cursor.execute(sql)# 提交到数据库执行db.commit()except:# Rollback in case there is any errordb.rollback()# 关闭数据库连接db.close()以上例子也可以写成如下形式：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb# 打开数据库连接db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 插入语句sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \LAST_NAME, AGE, SEX, INCOME) \VALUES (’%s’, ’%s’, ’%d’, ’%c’, ’%d’ )" % \(’Mac’, ’Mohan’, 20, ’M’, 2000)try:# 执行sql语句cursor.execute(sql)# 提交到数据库执行db.commit()except:# 发生错误时回滚db.rollback()# 关闭数据库连接db.close()实例：以下代码使用变量向SQL语句中传递参数:..................................user_id = "test123"password = "password"con.execute(’insert into Login values("%s", "%s")’ % \(user_id, password))..................................数据库查询操作Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。fetchone(): 该方法获取下一个查询结果集。结果集是一个对象fetchall():接收全部的返回结果行.rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。实例：查询EMPLOYEE表中salary（工资）字段大于1000的所有数据：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb# 打开数据库连接db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 查询语句sql = "SELECT * FROM EMPLOYEE \WHERE INCOME 》 ’%d’" % (1000)try:# 执行SQL语句cursor.execute(sql)# 获取所有记录列表results = cursor.fetchall()for row in results:fname = rowlname = rowage = rowsex = rowincome = row# 打印结果print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \(fname, lname, age, sex, income )except:print "Error: unable to fecth data"# 关闭数据库连接db.close()以上脚本执行结果如下：fname=Mac, lname=Mohan, age=20, sex=M, income=2000数据库更新操作更新操作用于更新数据表的的数据，以下实例将 TESTDB表中的 SEX 字段全部修改为 ’M’，AGE 字段递增1：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb# 打开数据库连接db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 更新语句sql = "UPDATE EMPLOYEE SET AGE = AGE + 1WHERE SEX = ’%c’" % (’M’)try:# 执行SQL语句cursor.execute(sql)# 提交到数据库执行db.commit()except:# 发生错误时回滚db.rollback()# 关闭数据库连接db.close()删除操作删除操作用于删除数据表中的数据，以下实例演示了删除数据表 EMPLOYEE 中 AGE 大于 20 的所有数据：#!/usr/bin/python# -*- coding: UTF-8 -*-import MySQLdb# 打开数据库连接db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 删除语句sql = "DELETE FROM EMPLOYEE WHERE AGE 》 ’%d’" % (20)try:# 执行SQL语句cursor.execute(sql)# 提交修改db.commit()except:# 发生错误时回滚db.rollback()# 关闭连接db.close()执行事务事务机制可以确保数据一致性。事务应该具有4个属性：原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。原子性（atomicity）。一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。一致性（consistency）。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。隔离性（isolation）。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。持久性（durability）。持续性也称永久性（permanence），指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。
python专业版本上如何直接创建数据库
import pymysql# 打开数据库db = pymysql.connect(host=’localhost’, port=3306, user=’root’, passwd=’root’, db=’lianxi’, charset=’utf8’)# 使用cursor()方法获取操作游标cursor = db.cursor()# 如果数据表已经存在使用execute()方法删除表cursor.execute("drop table if EXISTS income")# 创建数据库SQL语句# time,ironincome,general_income,baiincomeSQL = """CREATE TABLE `income` (`id` int(11) NOT NULL AUTO_INCREMENT,`datetime` varchar(20) DEFAULT NULL,`ironincome` decimal(20,2) DEFAULT NULL,`generalincome` decimal(20,2) DEFAULT NULL,`baiincome` decimal(20,2) DEFAULT NULL,PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;"""cursor.execute(SQL)db.close()
linux环境下python怎样操作mysql数据库
linux环境下python怎样操作mysql数据库呢？方法如下：
首先在Linux环境下安装mysql-python
1、下载mysql-python
打开终端：
cd /usr/local
***隐藏网址***
***隐藏网址***
2、解压
sudo tar -zxvf MySQL-python-1.2.2.tar.gz
cd MySQL-python-1.2.2
3、在安装前需进行配置
a、修改setup_posix.py中的mysql_config.path为你mysql安装目录的mysql_config路径
b、修改site.cfg中的threadsafe = False，去掉mysql_config前的注释，并改为mysql_config = /usr/local/mysql/bin/mysql_config
c、执行命令：
export LD_LIBRARY_PATH=/usr/local/mysql/lib/mysql
sudo ln -s /usr/local/mysql/lib/mysql/libmysqlclient.so /usr/lib/libmysqlclient.so.14
sudo ldconfig (这个很重要，否则后面会报错ImportError: libmysqlclient.so.14: cannot open shared object file)
4、编译安装
1）python setup.py build
若未成功的话，需手动安装setuptools：
sudo apt-get install python-setuptools2）sudo python setup.py install
5、测试
python
》》》 import MySQLdb
没有错误，则表示安装成功了。
使用python操作MySQL
使用python连接MySQL，创建数据库，创建表格，插入/查询数据。python_mysql.py代码如下：
效果如图：
若出现类似于此的警告：
/usr/local/lib/python2.6/dist-packages/MySQL_python-1.2.2-py2.6-linux-i686.egg/MySQLdb/__init__.py:34: DeprecationWarning: the sets module is deprecated from sets import ImmutableSet
解决办法如下：找到上面路径MySQLdb下的__init__.py文件1) 在文件中 "__init__.py"中， 注释掉:from sets import ImmutableSetclass DBAPISet(ImmutableSet):新增:class DBAPISet(frozenset):
2) 在文件"converters.py"中，注释掉 from sets import BaseSet, Set 这一句话。3) 在文件"converters.py"中， 修改 其中的"Set" 成为 "set" ( 只有两个地方需要修改，即大写改小写)
大概 line 45: return Set()
大概 line 129: Set: Set2Str, 改为 set: Set2Str,
1.引入MySQLdb库
import MySQLdb
2.和数据库建立连接
conn=MySQLdb.connect(host="localhost",user="root",passwd="sa",db="mytable",charset="utf8")
提供的connect方法用来和数据库建立连接,接收数个参数,返回连接对象.
比较常用的参数包括
host:数据库主机名.默认是用本地主机.
user:数据库登陆名.默认是当前用户.
passwd:数据库登陆的秘密.默认为空.
db:要使用的数据库名.没有默认值.
port:MySQL服务使用的TCP端口.默认是3306.
charset:数据库编码.
然后,这个连接对象也提供了对事务操作的支持,标准的方法
commit() 提交
rollback() 回滚
3.执行sql语句和接收返回值
cursor=conn.cursor()
n=cursor.execute(sql,param)
首先,我们用使用连接对象获得一个cursor对象,接下来,我们会使用cursor提供的方法来进行工作.这些方法包括两大类:1.执行命令,2.接收返回值
cursor用来执行命令的方法:
callproc(self, procname, args):用来执行存储过程,接收的参数为存储过程名和参数列表,返回值为受影响的行数
execute(self, query, args):执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数
executemany(self, query, args):执行单条sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数
nextset(self):移动到下一个结果集
cursor用来接收返回值的方法:
fetchall(self):接收全部的返回结果行.
fetchmany(self, size=None):接收size条返回结果行.如果size的值大于返回的结果行的数量,则会返回cursor.arraysize条数据.
fetchone(self):返回一条结果行.
scroll(self, value, mode=’relative’):移动指针到某一行.如果mode=’relative’,则表示从当前所在行移动value条,如果mode=’absolute’,则表示从结果集的第一行移动value条.
下面的代码是一个完整的例子.
#使用sql语句,这里要接收的参数都用%s占位符.要注意的是,无论你要插入的数据是什么类型,占位符永远都要用%s
sql="insert into cdinfo values(%s,%s,%s,%s,%s)"
#param应该为tuple或者list
param=(title,singer,imgurl,url,alpha)
#执行,如果成功,n的值为1
n=cursor.execute(sql,param)
#再来执行一个查询的操作
cursor.execute("select * from cdinfo")
#我们使用了fetchall这个方法.这样,cds里保存的将会是查询返回的全部结果.每条结果都是一个tuple类型的数据,这些tuple组成了一个tuple
cds=cursor.fetchall()
#因为是tuple,所以可以这样使用结果集
print cds
#或者直接显示出来,看看结果集的真实样子
print cds
#如果需要批量的插入数据,就这样做
sql="insert into cdinfo values(0,%s,%s,%s,%s,%s)"
#每个值的集合为一个tuple,整个参数集组成一个tuple,或者list
param=((title,singer,imgurl,url,alpha),(title2,singer2,imgurl2,url2,alpha2))
#使用executemany方法来批量的插入数据.这真是一个很酷的方法!
n=cursor.executemany(sql,param)
4.关闭数据库连接
需要分别的关闭指针对象和连接对象.他们有名字相同的方法
cursor.close()
conn.close()
以上方法就可以了。
另外，附MySQLdb的相关资料
***隐藏网址***
python怎么与neo4j图数据库连接(neo4j创建数据库)
Neo4j是一个用Java实现、完全兼容ACID的图形数据库。数据以一种针对图形网络进行过优化的格式保存在磁盘上。具体可以去论坛看一下
