提示

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

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

建庫(kù)建表

注意connect()如果沒(méi)對(duì)應(yīng).db庫(kù)的話會(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語(yǔ)句并加載結(jié)果

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

import pandas as pd from sqlalchemy import create_engine# 創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)連接 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èn)題。

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