189 8069 5689
你需要使用中间服务层来与数据库对接，比如Java，PHP，node.js等等语言与数据库交互。html5本身是没办法直连数据库。
让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：域名申请、网络空间、营销软件、网站建设、城关网站维护、网站推广。
1、和数据库建立连接
2、执行sql语句,接收返回值
3、关闭数据库连接
1、MySQL数据库要用MySQLdb模块,但Python用来链接MySQL的第三方库MySQLdb不支持Python3.x
特别说明：我在我的电脑上实验时，我的python是2.7.2版本，安装对应版本的MySQLdb之后直接可以运行，并与数据库连接成功，所以如果大家也像我一样顺利的话，下面的就不需要看了，直接跳过，看第2点如何执行sql语句即可！如果安装之后出现异常，可以参考一下下面的解决办法。
连接的关键是安装MySQLdb模块要下载与Python相对应的版本：
下载好后安装，它会自动检测到计算机Python的安装路径，并自动填写模块解压路径（我的是：D:\ProgramFiles\ActivePython 2.6.6.17\Lib\site-packages\）。
但解压完成后并不能使用，还要修改MySQLdb模块下的一些文件：
①.在MySQLdb目录下（我的是：D:\ProgramFiles\ActivePython 2.6.6.17\Lib\site-packages\MySQLdb）找到__init__.py：
注释第34、35行的from setsimport ImmutableSet、class DBAPISet(ImmutableSet):，在后面添加class DBAPISet(frozenset):
# from sets import ImmutableSet
# class DBAPISet(ImmutableSet):
class DBAPISet(frozenset):
②.打开converters.py：
注释第37行的from sets import BaseSet, Set，将第45行的return Set([ i for i in s.split(',') ifi ])中的Set改为set；同样将第129行的Set: Set2Str,中的Set改为set（不要修改Set2Str），到这里就修改完毕了
2.建立数据库连接
import MySQLdb
conn=MySQLdb.connect(host="localhost",user="root",passwd="sa",db="mytable")
比较常用的参数包括
host: 连接的数据库服务器主机名，默认为本地主机(localhost)。
user:数据库登陆名.默认是当前用户.
passwd:数据库登陆的秘密.默认为空.
db:要使用的数据库名.没有默认值.
port:MySQL服务使用的TCP端口.默认是3306.
conn连接有两个重要的方法commit【提交新增和修改】,rollback【撤销新增或修改】
3、执行数据库操作
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[0][3]
#或者直接显示出来,看看结果集的真实样子
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)
需要注意的是(或者说是我感到奇怪的是),在执行完插入或删除或修改操作后,需要调用一下conn.commit()方法进行提交.这样,数据才会真正保存在数据库中.我不清楚是否是我的mysql设置问题,总之,今天我在一开始使用的时候,如果不用commit,那数据就不会保留在数据库中,但是,数据确实在数据库呆过.因为自动编号进行了累积,而且返回的受影响的行数并不为0.
4、关闭数据库连接
需要分别的关闭指针对象和连接对象.他们有名字相同的方法
cursor.close()
conn.close()
5、
5 编码（防止乱码）
需要注意的点：
1 Python文件设置编码 utf-8 （文件前面加上 #encoding=utf-8)
2 MySQL数据库charset=utf-8
3 Python连接MySQL是加上参数 charset=utf8
4 设置Python的默认编码为 utf-8 (sys.setdefaultencoding(utf-8)
#encoding=utf-8
import sys
import MySQLdb
reload(sys)
sys.setdefaultencoding('utf-8')
db=MySQLdb.connect(user='root',charset='utf8')
注：MySQL的配置文件设置也必须配置成utf8
6.模块功能演示
#!/usr/bin/python
import MySQLdb
Con= MySQLdb.connect(host='localhost',user='root',passwd='root',db='abc')
cursor =con.cursor()
sql ="select * from myt"
cursor.execute(sql)
row=cursor.fetchone()
print row
cursor.close()
con.close()
执行以下SQL语句获取返回值：
//获取连接的游标
cursor=conn.cursor()
//查询
sql = "select * from 【table】"
//新增
sql = "insert into 【table】(字段,字段) values(值，值)"
//修改
sql = "update 【table】 set 字段 =‘值’where 条件 "
//删除
sql = "delete from 【table】where 条件"
cursor.execute(sql)
返回值
cur.execute('select * from tables')
其返回值为SQL语句得到的行数，如：2L，表示2行。
然后，可以从该对象的fetchone或fetchall方法得到行信息。
获取行信息
指针对象的fetchone()方法，是每次得到一行的tuple返回值：
引用
row=cur.fetchone()
print row
('user1', '52c69e3a57331081823331c4e69d3f2e', 1000L, 1000L, '/home/FTP/user1','')
指针对象的fetchall()方法，可取出指针结果集中的所有行，返回的结果集一个元组(tuples)：
引用
cur.scroll(0,'absolute')
row=cur.fetchall()
print row
(('user1', '52c69e3a57331081823331c4e69d3f2e', 1000L, 1000L, '/home/FTP/user1',''), ('user2', '7e58d63b60197ceb55a1c487989a3720', 1000L, 1000L,'/home/FTP/user2', None))
移动指针
当使用fetchone()方法是，指针是会发生移动的。所以，若不重置指针，那么使用fetchall的信息将只会包含指针后面的行内容。
手动移动指针使用：
cur.scroll(int,parm)
含义为：
引用
int：移动的行数，整数；在相对模式下，正数向下移动，负值表示向上移动。
parm：移动的模式，默认是relative，相对模式；可接受absoulte，绝对模式。
修改数据
修改数据，包括插入、更新、删除。它们都是使用指针对象的execute()方法执行：
cur.execute("insert into table (row1, row2) values ('111', '222')")
cur.execute("update table set row1 = 'test' where row2 = 'row2' ")
cur.execute("delete from table where row1 = 'row1' ")
因单引号“'”用于SQL语句中的标识，所以，python中的字符串需使用双引号括住。
此外，也可以使用python的“格式化字符串”写法，简化命令，例如：
cur.execute("update table set row1 = '%s' where row2 = '%s' "%('value1','value2'))
※请注意，'%s'的单引号是SQL语句的间隔符，'value1'的单引号是python的字符串间隔符，其含义是不同的。是否需要间隔符，以及使用双引号还是单引号作为间隔，需根据其含义决定。例如，还有：
cur.execute("update FTPUSERS set passwd=%s where userid='%s' "%("md5('123')",'user2'))
这里，paswd=%s是因SQL的md5()函数是不需要单引号间隔的；"md5('123')"是python的字符串中含有单引号，所以用双引号括住。
提交修改
一般情况下，MySQLdb模块会自动提交修改。但我们在更新数据后，手动运行一次：
conn.commit()
关闭数据库连接
需要分别的关闭指针对象和连接对象.他们有名字相同的方法
cursor.close()
conn.close()
接收MySQL数据
点击JavaScript,进入配置页面，在1处填入dip名字，2处的地址为宿主机地址，默认为dip系统部署机器地址, 点击下一步，填写脚本配置网页链接
dip名称：使用英文且见名知义(最好使用驼峰命名法)。
dip的宿主机：运行该dip的服务器ip地址，也是我们的数据处理服务器。
进入如下界面，在黑窗口的run函数中编写JavaScript脚本，将获取到的数据转换成产品需要的数据结构，最后输出。
首先编写脚本获取数据，获取数据有2种方式，第一种是主动获取，第二种是被动接收，根据实际情况选择对应的获取数据方式。而每一种方式又有多种类型。
对接MySQL我们选择主动获取方式，点击输入-主动获取，选择第一项MySQL ,相应的接入MySQL的代码会自动填写在function run() 里面 ，in 为接入语句，executes为数据处理逻辑，outs处填写数据输出语句。
如下图，在1处添加接入MySQL数据源url，username，password，在2处添加查询简单的查询sql语句，查询自己需要的数据。
function run() {
var MysqlJdbcAdapter = Java.type("com.uinnova.di.dicom.jdbc.MysqlJdbcAdapter");
while (true) {
try {
var adapter = new MysqlJdbcAdapter("jdbc:mysql://127.0.0.1:3306/database?useUnicode=truecharacterEncoding=UTF-8", "root", "root");
var data = adapter.getDataByTable("select * from ...");
heartBeat.addInCount(data.size());
//executes...
//outs...
sleep(60000);
} catch (error) {
logger.error("脚本执行错误：",error);
}
}}
接收ActiveMq数据
点击JavaScript,进入配置页面，在1处填入dip名字，2处的地址为宿主机地址，默认为dip系统部署机器地址, 点击下一步，填写脚本配置。
dip名称：使用英文且见名知义(最好使用驼峰命名法)。
dip的宿主机：运行该dip的服务器ip地址，也是我们的数据处理服务器。
在 Python 语言环境下我们这样连接数据库。
In [1]: from mysql import connector
In [2]: cnx = connector.connect(host="172.16.192.100",port=3306,user="appuser",password="xxxxxx")
但是连接数据库的背后发生了什么呢？
答案
当我们通过驱动程序（mysql-connector-python,pymysql）连接 MySQL 服务端的时候，就是把连接参数传递给驱动程序，驱动程序再根据参数会发起到 MySQL 服务端的 TCP 连接。当 TCP 连接建立之后驱动程序与服务端之间会按特定的格式和次序交换数据包，数据包的格式和发送次序由 MySQL 协议 规定。MySQL 协议：整个连接的过程中 MySQL 服务端与驱动程序之间，按如下的次序发送了这些包。
MySQL 服务端向客户端发送一个握手包，包里记录了 MySQL-Server 的版本，默认的授权插件，密码盐值（auth-data）。
2. MySQL 客户端发出 ssl 连接请求包（如果有必要的话）。
3. MySQL 客户端发出握手包的响应包，这个包时记录了用户名，密码加密后的串，客户端属性，等等其它信息。
4. MySQL 服务端发出响应包，这个包里记录了登录是否成功，如果没有成功也会给出错误信息。
Navicat for MySQL 功能简介
发布时间：2015-09-22
Navicat for MySQL 是一套管理和开发 MySQL 或 MariaDB 的理想解决方案，支持单一程序，可同时连接到 MySQL和MariaDB。这个功能齐备的前端软件为数据库管理、开发和维护提供了直观而强大的图形界面，给 MySQL 或 MariaDB 新手以及专业人士提供了一组全面的工具。
Navicat for MySQL 可连接到任何本机或远程 MySQL 和 MariaDB 服务器。它可以用于 MySQL 数据库服务器版本3.21或以上和 MariaDB 5.1或以上，与Drizzle、OurDelta 和 Percona Server 兼容，并支持大部分最新功能，包括表、视图、函数或过程、事件等。
主要功能包括 SQL 创建工具或编辑器、数据模型工具、数据传输、导入或导出、数据或结构同步、报表、以及更多。
Navicat for MySQL主要功能如下：
Navicat Cloud
Navicat for MySQL 提供 Navicat Cloud 服务给用户，同步连接设置、模型、查询和虚拟组到云。这样就能随时随地实时访问。有了 Navicat Cloud，便可以善用一天中的每分每秒，最大限度提高工作效率。
安全连接
Navicat 可通过 SSH 通道创建安全的 SSH 阶段作业，确保两台主机之间的连接受到强大验证和安全加密的保护,验证方式可使用密码、公钥、私钥。Navicat 也支持 HTTP 通道，直接连接互联网服务供应商。
对象设计器
Navicat for MySQL对象设计器
使用专业的对象设计器创建、修改和设计所有数据库对象，例如：表、视图、触发器和索引。无需编写复杂的 SQL 来创建和编辑对象。
表查看器
Navicat for MySQL查看网格或表单
查看网格或表单：使用网格查看添加、修改和删除记录。用类似数据表的功能浏览网格查看，例如排序和隐藏数据组，使用 Navicat for MySQL 助理编辑器：备注、十六进制、图像或更多，也可以用表单查看操作记录，清楚显示记录的栏位名和其值，不必担心误解数据。
Navicat for MySQL选择外键数据
选择外键数据：使用外键关系选定参考查找表，并自动建立下拉列表。无需持续对照参考主表，简化工作流程和提高效率。
SQL 创建工具或编辑器
Navicat SQL 创建工具
SQL 创建工具：视觉化 SQL 创建工具创建和编辑查询或视图，不必担心语法和正确命令的用法。选择需要在表中执行的操作，自动编写 SQL 语句。
Navicat for MySQL自动完成代码
自动完成代码：使用自动完成代码功能，能快速地在 SQL 编辑器中创建 SQL 语句。无论选择数据库对象的属性或 SQL 关键字，只需从下拉列表中选择。
数据库设计器
Navicat for MySQL逆向工程
逆向工程：使用 Navicat for MySQL逆向工程，可从一个现有的数据库创建数据库模型，可视化地显现和编辑数据库结构或创建一个图形模型，并由模型生成一个数据库。
Navicat for MySQL正向工程和生成脚本
正向工程和生成脚本：同步到数据库功能可充分了解所有数据库的差异，生成必要的同步脚本来更新目标数据库，并使其与模型相同。导出 SQL 有机会全面控制最终的 SQL 脚本，生成参照完整性规则，生成模型的独立部份、注释、字符集等，可大大节省工作时间。
数据处理工具
导入或导出向导：从不同格式的文件导入数据到表，例如 Access、Excel、XML、TXT、CSV、JSON 及更多。而且在设置数据源连接后，可以从 ODBC 导入数据。只需简单地选择需要导入的表，或使用添加查询按钮指定查询。同样可以将数据导出到各种格式，如 Excel、TXT、CSV、DBF、XML 等。
Navicat for MySQL数据传输
数据传输：在多个数据库间轻松地传输数据，可以选择指定的 SQL 格式和编码导出数据为 SQL 文件，这个功能可大大的简化迁移数据的进程。
Navicat 数据或结构同步
数据或结构同步：从一个数据库中详细的分析进程传输数据到另外一个数据库，同样可以对比并修改表的结构。在数据和结构同步中，目标数据库可以在源服务器，也可以在其他的服务器。
Navicat for MySQL备份或还原
备份或还原：定期备份数据库对用户涞水相当重要，备份或还原全部表、记录、视图等。如果数据损坏，不用再重做，高枕无忧。
Navicat for MySQL批处理作业
计划：不同数据库的设置文件可以创建在单一批处理作业，这样就可以设置计划并在指定的时间运行。批处理作业可以创建的对象包括打印报表、查询、数据传输、数据 同步、导入和导出。而且可传送电子邮件通知给指定的收件人，获取最新的计划信息。此外导出的文件或打印的报表可以添加到批处理作业作为电子邮件附件，轻易与其他人共享数据。
报表创建工具或查看器 只限于 Windows 版本
Navicat for MySQL 报表创建工具
使用用户友好 GUI 报表创建工具创建各种不同类型的报表，设计发票、统计、邮寄标签及更多其他报表。输出报表到多种格式，如 text、PDF、Lotus、Excel、Graphic、Html 及更多。Navicat Report Viewer 可浏览由报表创建工具设计的报表，最酷的是可以与没有安装 Navicat 但安装了 Navicat Report Viewer 的计算机共享报表。
实用工具
Navicat for MySQLER 图表
ER 图表：ER 图表能通过图形格式显示数据库结构，帮助用户了解数据库，看到数据库中表之间的关联。
Navicat for MySQL连接颜色或虚拟组
连接颜色或虚拟组：连接颜色功能可立刻知道连接到哪个服务器，显示在子窗口工具栏的颜色指示，用于识别连接和它们的数据库对象。虚拟组工具可将对象分类到不用的组，令对象和连接有一个更好的组织。
Navicat for MySQL树或对象筛选功能
树或对象筛选：使用树或对象筛选功能可设计显示数据对象的列表，简单地需输入文本，就只显示符合指定字符串的数据库对象。
收藏夹
Navicat for MySQL可帮助用户容易地回到经常访问的数据库对象，通过添加路径到收藏列表，只需一次点击就可以打开这些数据库对象。
详细的图文教程可以参考：
linux环境下python怎样操作mysql数据库呢？方法如下：
首先在Linux环境下安装mysql-python
1、下载mysql-python
打开终端：
cd /usr/local
sudo wget
官网地址：
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-setuptools
2）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 ImmutableSet
class DBAPISet(ImmutableSet):
新增:
class DBAPISet(frozenset):
2) 在文件"converters.py"中，注释掉 from sets import BaseSet, Set 这一句话。
3) 在文件"converters.py"中， 修改 其中的"Set" 成为 "set" ( 只有两个地方需要修改，即大写改小写)
大概 line 45: return Set([ i for i in s.split(',') if i ]) 改为 return set([ i for i in s.split(',') if i ])
大概 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[0][3]
#或者直接显示出来,看看结果集的真实样子
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的相关资料
更多关于MySQLdb的信息可以查这里：