熊猫和sqlalchemy的死简单包装
sqlsorcer的Python项目详细描述
sqlsorcery
用于pandas和sqlalchemy的简单包装
依赖关系
- Python3.7
- pipenv
- MS SQL ODBC驱动程序
开始
- 安装此库
$ pipenv install sqlsorcery
- 安装MS SQL驱动程序
wget https://packages.microsoft.com/debian/9/prod/pool/main/m/msodbcsql17/msodbcsql17_17.2.0.1-1_amd64.deb
apt-get update
apt-get install -y apt-utils unixodbc unixodbc-dev
yes | dpkg -i msodbcsql17_17.2.0.1-1_amd64.deb
- 使用环境凭据设置
.env文件
单一数据库环境：
DB_SERVER=
DB_PORT=
DB=
DB_USER=
DB_PWD=
对于多数据库环境，请使用特定于SQL的前缀或在实例化时指定连接变量：
PG_SERVER=
PG_PORT=
PG_DB=
PG_USER=
PG_PWD=
MS_SERVER=
MS_DB=
MS_USER=
MS_PWD=
或
fromsqlsorceryimportMSSQLsql=MSSQL(server="server_host",db="dba_name",user="username",pwd="password")
示例
查询表格：
fromsqlsorceryimportMSSQLsql=MSSQL()df=sql.query("SELECT * FROM my_table")print(df)
来自.sql文件的查询：
fromsqlsorceryimportMSSQLsql=MSSQL()df=sql.query_from_file("filename.sql")print(df)
插入表格：
fromsqlsorceryimportMSSQLimportpandasaspdsample_data=[{"name":"Test 1","value":98},{"name":"Test 2","value":100},]df=pd.DataFrame(sample_data)sql=MSSQL()sql.insert_into("table_name",df)
执行存储过程：
fromsqlsorceryimportMSSQLsql=MSSQL()sql.exec_sproc("sproc_name")
欢迎加入QQ群-->： 979659372
