连接数据库

通过yaspy模块提供的connect函数建立数据库连接，并返回一个连接对象（Connection）：

connection=yaspy.connect(
	dsn='127.0.0.1:1688',
	user='sales',
	password='sales',
)

连接串说明

参数	描述
dsn	数据库连接描述符。格式如下： host:port * host：主机域名或IP地址，需配置为单机实例服务器地址或分布式CN服务器地址； * port：数据库服务端口，如1688。
user	数据库用户名。
password	数据库用户密码。

示例：

import yaspy
#连接数据库
connection=yaspy.connect(
	dsn='127.0.0.1:1688',
	user='sales',
	password='sales',
)
#创建游标对象
cursor =connection.cursor()
#执行SQL语句
cursor.execute("drop table if exists example_table")
cursor.execute("create table example_table(id int , name varchar(32))")
cursor.execute("insert into example_table values(1,'test1')")
connection.commit()
cursor.execute("insert into example_table values(?,?)",(2,'test2'))
data=(3,'test3')
cursor.execute("insert into example_table values(?,?)",data)
connection.commit()
#关闭游标对象
cursor.close()
#关闭数据库连接
connection.close()

执行SQL

调用Connection的cursor()方法创建并返回一个游标对象（Cursor），该游标对象可用于执行语句和获取结果。

cursor =connection.cursor()

执行SQL语句

调用Cursor的execute()方法执行SQL语句，并通过commit()方法将挂起的事务提交到数据库。

cursor.execute("drop table if exists example_table")
cursor.execute("create table example_table(id int , num int)")
cursor.execute("insert into example_table values(1,'test1')")
connection.commit()

执行带参数的SQL语句

cursor.execute("insert into example_table values(?,?)",(2,'test2'))
data=(3,'test3')
cursor.execute("insert into example_table values(?,?)",data)
connection.commit()

关闭游标对象

调用Cursor的close()方法后，该游标将不再可用。

cursor.close()

关闭数据库连接

调用Connection的close()方法后，该连接将不再可用。

connection.close()