SQL 炼金术检查连接
SQL Alchemy Check Connection
我使用 SQL Alchemy 和 Pyodbc 创建了以下连接到 SQL 服务器的方法。
def getDBEngine(server, database):
Params = urllib.quote_plus("DRIVER={SQL Server};SERVER="+server+";DATABASE="+database+";TRUSTED_CONNECTION=Yes")
Engine = sa.create_engine("mssql+pyodbc:///?odbc_connect=%s" % Params)
return Engine
然后我可以使用该引擎通过以下方法从 pandas 中的 to_sql 等方法读取和写入数据。
def toSQL(Server, Database, Tablename):
writeEngine= getDatabaseEngine(Server, Database)
data.to_sql('write_Tablename',writeEngine,if_exists='append')
我的问题是是否有一种简单的方法可以在实际使用引擎读取或写入数据之前检查引擎的连接/状态。最简单的方法是什么?
我在多次交战中看到的一种模式本质上是一种有效 select 1 as is_alive;
的“存活”检查。没有数据访问权限,所以它只是检查您的连接在哪里可以接受来自您的应用程序的命令。
我使用 SQL Alchemy 和 Pyodbc 创建了以下连接到 SQL 服务器的方法。
def getDBEngine(server, database):
Params = urllib.quote_plus("DRIVER={SQL Server};SERVER="+server+";DATABASE="+database+";TRUSTED_CONNECTION=Yes")
Engine = sa.create_engine("mssql+pyodbc:///?odbc_connect=%s" % Params)
return Engine
然后我可以使用该引擎通过以下方法从 pandas 中的 to_sql 等方法读取和写入数据。
def toSQL(Server, Database, Tablename):
writeEngine= getDatabaseEngine(Server, Database)
data.to_sql('write_Tablename',writeEngine,if_exists='append')
我的问题是是否有一种简单的方法可以在实际使用引擎读取或写入数据之前检查引擎的连接/状态。最简单的方法是什么?
我在多次交战中看到的一种模式本质上是一种有效 select 1 as is_alive;
的“存活”检查。没有数据访问权限,所以它只是检查您的连接在哪里可以接受来自您的应用程序的命令。