提示

建議采用 try…except…finally… 或者 try…finally… ，保證與數(shù)據(jù)庫的連接被關(guān)閉。

SQL語句入門很簡(jiǎn)單 （精深很難） ，不會(huì)的自己去簡(jiǎn)單學(xué)學(xué)。

建庫建表

注意connect()如果沒對(duì)應(yīng).db庫的話會(huì)自動(dòng)建一個(gè)。

import sqlite3try:connection = sqlite3.connect('sample.db')print("Opened database successfully")cursor = connection.cursor()cursor.execute('''CREATE TABLE COMPANY(ID INT PRIMARY KEY NOT NULL,NAME TEXT NOT NULL,AGE INT NOT NULL,ADDRESS CHAR(50),SALARY REAL);''')print("Table created successfully")connection.commit() finally:connection.close()

插入四行數(shù)據(jù)

import sqlite3try:connection = sqlite3.connect('sample.db')cursor = connection.cursor()print("Opened database successfully")cursor.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) VALUES (1, 'Sam', 32, 'BeiJing', 20000.00)")cursor.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) VALUES (2, 'Bob', 25, 'ShangHai', 15000.00)")cursor.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) VALUES (3, 'Jack', 23, 'Norway', 20000.00)")cursor.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) VALUES (4, 'Tom', 25, 'GuangZhou', 65000.00)")connection.commit()print("Records created successfully") finally:connection.close()

使用pandas的read_sql_query執(zhí)行SQL語句并加載結(jié)果

使用create_engine，定義了一個(gè)到SQLite數(shù)據(jù)庫引擎的連接，然后使用pandas庫中的read_sql_query，通過SQL語句查詢數(shù)據(jù)庫，并將結(jié)果存入一個(gè)DataFrame中。

import pandas as pd from sqlalchemy import create_engine# 創(chuàng)建一個(gè)數(shù)據(jù)庫連接 database_connection = create_engine('sqlite:///sample.db')# 加載數(shù)據(jù) dataframe = pd.read_sql_query('SELECT * FROM COMPANY', database_connection)# 查看前兩行數(shù)據(jù) print(dataframe.head(2))

查詢結(jié)果

ID NAME AGE ADDRESS SALARY 0 1 Sam 32 BeiJing 20000.0 1 2 Bob 25 ShangHai 15000.0

總結(jié)

以上是生活随笔為你收集整理的【Python】Pandas在数据库中执行SQL语句并加载结果的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。