Блог

Я пытаюсь подключиться к базе данных SQL и в цикле создать отдельные фреймы данных для каждого отдельного экземпляра идентификатора, содержащие все данные, связанные с этим идентификатором. Я пробовал несколько способов, но до сих пор безуспешно. Я довольно новичок во всем этом, так что, вероятно, совершаю некоторые ошибки новичка.

Попытка 1:

 import pandas as pd
import pyodbc

conn = pyodbc.connect('Driver={SQL Server};'
                      'Server=Server_name;'
                      'Database=Database;'
                      'UID=Username;'
                      'PWD=password;'
                      'Trusted_Connection=yes;')

Name = ['HR','ZA','PR','FW']

for x in Name:
    
    SQL = '''
        SELECT *
        FROM Database
        WHERE Id = {x}'''.format(x = x)
    cursor = conn.cursor()
    cursor.execute(SQL)
    df = pd.read_sql_query(SQL)
 

В этом коде я получаю ошибку программирования «недопустимое имя столбца» при первом имени «HL».

Попытка 2:

 import pandas as pd
import pyodbc

conn = pyodbc.connect('Driver={SQL Server};'
                      'Server=Server_name;'
                      'Database=Database;'
                      'UID=Username;'
                      'PWD=password;'
                      'Trusted_Connection=yes;')

    SQL = '''
        SELECT *
        FROM Database
    
conn.autocommit = True

cursor.execute(SQL)

for [Id] in cursor:
    df = pd.Dataframe(SQL,conn)
        
 

В этом коде я получаю «Ошибка значения: слишком много значений для распаковки (ожидается 1)» — в операторе for.

Я хочу добавить гораздо больше кода в цикл for, поэтому мне нужно настроить его для работы с каждым идентификатором. Я надеюсь, что в этом есть смысл. Любые рекомендации будут весьма признательны. Спасибо

Обновить:

Спасибо за все комментарии/ответы. По какой-то причине я просто не мог заставить его работать ни в одном из вышеперечисленных форматов, поэтому я вернулся к тому, с чего начал, теперь я понимаю, как включить синтаксис переменной цикла. Теперь работает следующее:

 import pandas as pd
import pyodbc

conn = pyodbc.connect('Driver={SQL Server};'
                          'Server=Server_name;'
                          'Database=Database;'
                          'UID=Username;'
                          'PWD=password;'
                          'Trusted_Connection=yes;')
    
Name = ['HR','ZA','PR','FW']

for x in Name:

    SQL = pd.read_sql_query(
    '''
    SELECT *
    FROM Database_table
    WHERE Id = '{x}'
    '''.format(x = x), conn)

    df = pd.DataFrame(SQL)
    
 

Я думаю, что если вы попробуете вариант с вашей первой попытки, например:

 for x in Name:

    SQL = '''
          SELECT *
          FROM Database
          WHERE Id = ?'''
    cursor = conn.cursor()
    cursor.execute(SQL)
    df = pd.read_sql_query(SQL, params={x})
 

Вероятно, это должно сработать 🙂