sql数据库代码(Python ?本栏目通过对sql数据库代码10038, sql数据库简单代码问题整理,来做出以下的解答希望对你有所帮助。

获取数据库
首先把连接数据的信息写入 database.ini 文本文件中,内容如下:
[postgresql]
host=localhost
database=dbname
user=postgres
password=
然后定义一个读取database.ini文件的函数,代码如下:
import psycopg2from configparser import ConfigParserdef load_config(filename='database.ini', section='postgresql'): parser = ConfigParser() parser.read(filename) # 获取数据库的设置参数 config = {} if parser.has_section(section): params = parser.items(section) for param in params: config[param[0]] = param[1] else: raise Exception(' 在 {0} 文件中没有发现参数 {1}'.format(filename,section)) return configif __name__ == '__main__': config = load_config() print(config)
以上代码运行结果如下:
{'host': 'localhost', 'database': 'dbname', 'user': 'postgres', 'password': ''}
建立数据库连接
import psycopg2from config import load_configdef connect(config): try: with psycopg2.connect(**config) as conn: print('已连接到 PostgreSQL server.') return conn except (Exception. psycopg2.DatabaseError ) as error: print(error)if __name__ == '__main__': config = load_config() connect(config) 创建数据表
# import psycopg2# from config import load_config# 增加一个新的零部件def add_part(part_name, vendor_name): # 读取数据库参数 params = load_config() try: # 连接数据库 with psycopg2.connect(**params) as conn: with conn.cursor() as cur: # 调用一个存储过过程 cur.execute('CALL add_new_part(%s,%s)', (part_name, vendor_name)) # 提交数据变化到数据库 conn.commit() except (Exception, psycopg2.DatabaseError) as error: print(error)if __name__ == '__main__': add_part('液晶板', '京东方')事务处理
(本文完)
sql数据库代码(Python 相关信息就介绍到这里,sql数据库代码10038, sql数据库简单代码的问题希望对你有所帮助。