解決一個(gè)pandas執(zhí)行模糊查詢(xún)sql的坑
查詢(xún)引擎使用了presto,在sql中使用了模糊查詢(xún)。
engine = create_engine(presto_url,encoding='utf-8') sql_exe ="""select id,title,tags from source.base.table where tags like '%呵呵%' """ df = pd.read_sql_query(sql_exe,engine)
一直報(bào)錯(cuò):
unsupported format character
解決方案
第一:
sql_exe ="""select id,title,tags from source.base.table where tags like '%%呵呵%%' """
第二:
sql_exe ="""select id,title,tags from source.base.table where tags like %s """
df = pd.read_sql_query(sql_exe,engine,params=("%呵呵%",))
補(bǔ)充:pd.read_sql()知道這些就夠用了
如下:
pandas.read_sql(sql, con, index_col=None, coerce_float=True, params=None, parse_dates=None, columns=None, chunksize=None)
各參數(shù)意義
sql:SQL命令字符串
con:連接sql數(shù)據(jù)庫(kù)的engine,一般可以用SQLalchemy或者pymysql之類(lèi)的包建立
index_col: 選擇某一列作為index
coerce_float:非常有用,將數(shù)字形式的字符串直接以float型讀入
parse_dates:將某一列日期型字符串轉(zhuǎn)換為datetime型數(shù)據(jù),與pd.to_datetime函數(shù)功能類(lèi)似。可以直接提供需要轉(zhuǎn)換的列名以默認(rèn)的日期形式轉(zhuǎn)換,也可以用字典的格式提供列名和轉(zhuǎn)換的日期格式,比如{column_name: format string}(format string:"%Y:%m:%H:%M:%S")。
columns:要選取的列。一般沒(méi)啥用,因?yàn)樵趕ql命令里面一般就指定要選擇的列了
chunksize:如果提供了一個(gè)整數(shù)值,那么就會(huì)返回一個(gè)generator,每次輸出的行數(shù)就是提供的值的大小。
設(shè)置參數(shù)can–>創(chuàng)建數(shù)據(jù)庫(kù)鏈接的兩種方式
用sqlalchemy構(gòu)建數(shù)據(jù)庫(kù)鏈接
import pandas as pd
import sqlalchemy
from sqlalchemy import create_engine
# 用sqlalchemy構(gòu)建數(shù)據(jù)庫(kù)鏈接engine
connect_info = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'
engine = create_engine(connect_info)
# sql 命令
sql_cmd = "SELECT * FROM table"
df = pd.read_sql(sql=sql_cmd, con=engine)
用DBAPI構(gòu)建數(shù)據(jù)庫(kù)鏈接
import pandas as pd import pymysql # sql 命令 sql_cmd = "SELECT * FROM table" # 用DBAPI構(gòu)建數(shù)據(jù)庫(kù)鏈接engine con = pymysql.connect(host=localhost, user=username, password=password, database=dbname, charset='utf8', use_unicode=True) df = pd.read_sql(sql_cmd, con)
read_sql與read_sql_table、read_sql_query
read_sql本質(zhì)上是read_sql_table、read_sql_query的統(tǒng)一方式。
三者都return返回DataFrame。
1、read_sql_table
Read SQL database table into a DataFrame.
2、read_sql_query
Read SQL query into a DataFrame.
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
相關(guān)文章
解決Django migrate No changes detected 不能創(chuàng)建表的問(wèn)題
今天小編就為大家分享一篇解決Django migrate No changes detected 不能創(chuàng)建表的問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-05-05
python使用arp欺騙偽造網(wǎng)關(guān)的方法
這篇文章主要介紹了python使用arp欺騙偽造網(wǎng)關(guān)的方法,涉及Python偽造網(wǎng)關(guān)的相關(guān)技巧,需要的朋友可以參考下2015-04-04
Python函數(shù)基礎(chǔ)實(shí)例詳解【函數(shù)嵌套,命名空間,函數(shù)對(duì)象,閉包函數(shù)等】
這篇文章主要介紹了Python函數(shù)基礎(chǔ),結(jié)合實(shí)例形式詳細(xì)分析了函數(shù)嵌套,命名空間,函數(shù)對(duì)象,閉包函數(shù)等相關(guān)概念、原理、用法及操作注意事項(xiàng),需要的朋友可以參考下2019-03-03
神經(jīng)網(wǎng)絡(luò)訓(xùn)練采用gpu設(shè)置的方式
這篇文章主要介紹了神經(jīng)網(wǎng)絡(luò)訓(xùn)練采用gpu設(shè)置的方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-03-03
python重用父類(lèi)功能的兩種方式實(shí)例詳解
這篇文章主要介紹了python重用父類(lèi)功能的兩種方式,方式一是跟繼承沒(méi)有關(guān)系的,而方式二的super()是依賴(lài)于繼承的,并且即使沒(méi)有直接繼承關(guān)系,super()仍然會(huì)按照MRO繼續(xù)往后查找,本文給大家介紹的非常詳細(xì),需要的朋友可以參考下2022-09-09
Python利用atexit模塊實(shí)現(xiàn)優(yōu)雅處理程序退出
Python的atexit模塊提供了一種方便的方式來(lái)注冊(cè)這些退出時(shí)執(zhí)行的函數(shù),文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-03-03

