Функция read_sql_table

Функция read_sql_table загружает содержимое указанной таблицы из SQL базы данных в DataFrame. Первым параметром передаётся имя таблицы, вторым параметром - соединение с базой данных. Дополнительно можно указать список столбцов для загрузки, условия фильтрации через SQL запрос и параметры чтения по частям. Функция возвращает DataFrame с загруженными данными.

Синтаксис

pd.read_sql_table(
	table_name,
	con,
	schema=None,
	index_col=None,
	coerce_float=True,
	columns=None,
	chunksize=None
)

Пример

Давайте загрузим все данные из таблицы 'users':

import pandas as pd
from sqlalchemy import create_engine

engine = create_engine('sqlite:///example.db')
df = pd.read_sql_table('users', engine)
print(df.head())

Результат выполнения кода:

   id	 name   age
0  1	Alice	25
1  2	  Bob	30
2  3  Charlie	35
3  4	Diana	28
4  5	Emily	22

Пример

Давайте загрузим только определённые столбцы из таблицы 'products':

import pandas as pd
from sqlalchemy import create_engine

engine = create_engine('sqlite:///example.db')
df = pd.read_sql_table(
	'products',
	engine,
	columns=['name', 'price']
)
print(df.head())

Результат выполнения кода:

   name  price
0  item1  100
1  item2  200
2  item3  150
3  item4  300
4  item5  250

Пример

Давайте загрузим данные по частям с использованием параметра chunksize:

import pandas as pd
from sqlalchemy import create_engine

engine = create_engine('sqlite:///example.db')
chunks = pd.read_sql_table(
	'logs',
	engine,
	chunksize=100
)
for chunk in chunks:
	print(f"rows found: {len(chunk)}")
	break

Результат выполнения кода:

"rows found: 100"

Пример

Давайте укажем столбец, который станет индексом DataFrame:

import pandas as pd
from sqlalchemy import create_engine

engine = create_engine('sqlite:///example.db')
df = pd.read_sql_table(
	'employees',
	engine,
	index_col='id'
)
print(df.head())

Результат выполнения кода:

  name  department
		id					 
		1	 John	   Sales
		2	 Anna		 IT
		3	 Mark   Marketing
		4	Sarah		 HR
		5   Victor		 IT

Смотрите также

функция read_sql,
которая загружает данные по SQL запросу
функция read_sql_query,
которая выполняет SQL запрос и возвращает DataFrame
функция read_csv,
которая читает данные из CSV файла
функция read_excel,
которая читает данные из Excel файла