Здравствуйте, у меня есть следующий код, который я использую для добавления таблиц данных в SQL-сервер
def push_to_sql(sql_table_name, dataframe, sql_conn):
try:
dataframe.to_sql(con=sql_conn, name=sql_table_name, if_exists='append', index=False,
chunksize=200)
logger.info("Pushed to the dataframe")
except Exception as ex:
logger.error(ex)
logger.warning("Please check SQL connection string or give a valid table name")
и ниже - формат строки подключения
def create_sql_engine(login, password, server_name, db_name, driver_name):
connection_string = 'mssql+pyodbc://' + login + ':' + password + '@' + server_name + '/' + db_name + '?' + 'driver=' + driver_name
engine = None
try:
engine = create_engine(connection_string)
logger.info("Connected to the database")
except Exception as ex:
logger.error(ex)
logger.warning("Please check the Sql Authentication Parameters")
return engine
Недавно я попробовал этокод для отправки данных в SQL Express (я изменил параметры на SQL Express), скрипт работает отлично, но я не вижу новых данных, добавленных в таблицы (в файле журнала также нет ошибок). У меня есть вседоступ на чтение пишите данные в SQL Express.Я что-то пропустил?Пожалуйста, помогите мне.
***** РЕДАКТИРОВАТЬ *****
login = 'default'
passw = 'somepassword'
server = 'server.ip\hostname'
db_name = 'TestDB'
driver = 'SQL Server Native Client 11.0'
engine = create_sql_engine(login, passw, server, db_name, driver)
if engine is None:
logger.warning("Cannot insert data as connection was not established")
else:
if df_from_file is not None:
push_to_sql('sample_table', df_from_file, engine)
else:
logger.warning("Dataframe is empty or File doesn't have valid encoding ")
Это пример использования, так как я не могу раскрыть какие-либо подробности строки подключения, я подтвердил, что nпроверил это.