pythonsql語句參數

⑴ python中sql語句多個 查詢條件的怎麼寫

python中有很多字元串連接方式，今天在寫代碼，順便總結一下：

1. 最原始的字元串連接方式：str1 + str2

2. python 新字元串連接語法：str1, str2

3. 奇怪的字元串方式：str1 str2

4. % 連接字元串：『name:%s; sex: 』 % ('tom', 'male')

5. 字元串列表連接：str.join(some_list)

第四種功能比較強大，借鑒了C語言中 printf 函數的功能，如果你有C語言基礎，看下文檔就知道了。這種方式用符號「%」連接一個字元串和一組變數，字元串中的特殊標記會被自動用右邊變數組中的變數替換。

試試這個

results=self.db.query(
'SELECTLP.IdLineProctId,LP.SupplierLineTitle,LP.MainTitle,LP.SubTitle,LP.ShowTitle,LPC.CityIdDestinationCityId,
LPC.CityNameDestinationCityName,LP.Days,LP.DataFlag,LP.IfDel,LP.RecomImage_IdsASLineProctRecomImage
FROM[TCZiZhuYou].dbo.[ZZY_LineProct]LPWITH(NOLOCK)
INNERJOIN[TCZiZhuYou].dbo.[ZZY_LineProctCity]LPCWITH(NOLOCK)ONLPC.LineProct_Id=LP.IdANDLPC.DataFlag=1ANDLPC.IsDestination=1
WHERELP.Id=%dANDLP.LineProctType=%d'%(line_id,line_type))[0]

⑵ python中的sql參數化，想向sql中傳入一組參數，要怎麼寫

一般的處理思路是將資料庫操作的方法放在一個模塊中，比如connectsql.py：
import mysqldb
def execnonquery(sql):
conn = mysqldb.connect(host='xxxx',user='xxxx',passwd='xxxx',db='xxxx')
cur = conn.cursor()
cur.execute(sql)
conn.commit()
conn.close()那麼你的a.py代碼為：
from connectsql import *
def mysql_insert(i,data):
try:
execnonquery('insert into mytest values(%s,%s)' % (i,data))
except:
return 0你的b.py代碼不變。

⑶ python 如何使用源生sql語句查詢多個參數的情況

#coding:utf-8
#anexample
"""
--theSQLServerstorageprocess:
dropprocereproc_getconflist
go
createprocereproc_getconflist
@customerchar(6)
,@servicekeyvarchar(16)=NULL
,@dt_bgndatetime=NULL
,@dt_enddatetime=NULL
asbegin
selectbillsumidxasidx
fromconf_billsum
where1=1
andsumtypeid=1
andisnull(@customer,customercode)=customercode
andisnull(@servicekey,servicekey)=servicekey
andisnull(@dt_bgn,begintime)<endtime
andbegintime<isnull(@dt_end,endtime)
end
go

"""

importpymssql

conn=pymssql.connect(
host="192.168.70.7",
user='pyquery',
password='Qpery',
database='gb201412',
)
curr=conn.cursor()
curr.execute("execproc_getconflist%s,%s,%s,%s",
('990003',None,None,None))
foridx,incurr:
printidx
curr.close()
conn.close()

⑷ python sql語句查詢問題

search= raw_input()

search.decode('gbk').encode('utf-8')
或者search= search.decode('utf-8').encode('gbk')

根據你資料庫 和py的編碼 把search 的編碼搞成一致的

⑸ 如何python獲取sql資料庫訪問的url

python
操作資料庫，要安裝一個Python和資料庫交互的包MySQL-python-1.2.2.win32-py2.5.exe，然後我們就可以使用MySQLdb這個包進行資料庫操作了。

操作步驟如下：
1、建立資料庫連接
import
MySQLdb
conn=MySQLdb.connect(host="localhost",user="root",passwd="sa",db="mytable")
cursor=conn.cursor()
2、執行資料庫操作
n=cursor.execute(sql,param)
我們要使用連接對象獲得一個cursor對象,接下來,我們會使用cursor提供的方法來進行工作.
這些方法包括兩大類:1.執行命令,2.接收返回值

3、cursor用來執行命令的方法:

callproc(self, procname,
args):用來執行存儲過程,接收的參數為存儲過程名和參數列表,返回值為受影響的行數
execute(self, query,
args):執行單條sql語句,接收的參數為sql語句本身和使用的參數列表,返回值為受影響的行數
executemany(self, query,
args):執行單挑sql語句,但是重復執行參數列表裡的參數,返回值為受影響的行數

nextset(self):移動到下一個結果集

4、cursor用來接收返回值的方法:


fetchall(self):接收全部的返回結果行.
fetchmany(self,
size=None):接收size條返回結果行.如果size的值大於返回的結果行的數量,則會返回cursor.arraysize條數據.

fetchone(self):返回一條結果行.
scroll(self, value,
mode='relative'):移動指針到某一行.如果mode='relative',則表示從當前所在行移動value條,如果mode='absolute',則表示從結果集的第一
行移動value條.

5、下面的代碼是一個完整的例子.

#使用sql語句,這里要接收的參數都用%s佔位符.要注意的是,無論你要插入的數據是什麼類型,佔位符永遠都要用%s
sql="insert
into cdinfo values(%s,%s,%s,%s,%s)"
#param應該為tuple或者list
param=(title,singer,imgurl,url,alpha)
#執行,如果成功,n的值為1
n=cursor.execute(sql,param)
#再來執行一個查詢的操作
cursor.execute("select
* from cdinfo")
#我們使用了fetchall這個方法.這樣,cds里保存的將會是查詢返回的全部結果.每條結果都是一個tuple類型的數據,這些tuple組成了一個tuple
cds=cursor.fetchall()
#因為是tuple,所以可以這樣使用結果集
print
cds[0][3]
#或者直接顯示出來,看看結果集的真實樣子
print
cds
#如果需要批量的插入數據,就這樣做
sql="insert
into cdinfo values(0,%s,%s,%s,%s,%s)"
#每個值的集合為一個tuple,整個參數集組成一個tuple,或者list
param=((title,singer,imgurl,url,alpha),(title2,singer2,imgurl2,url2,alpha2))
#使用executemany方法來批量的插入數據.這真是一個很酷的方法!
n=cursor.executemany(sql,param)
需要注意的是(或者說是我感到奇怪的是),在執行完插入或刪除或修改操作後,需要調用一下conn.commit()方法進行提交.這樣,數據才會真正保
存在資料庫中.我不清楚是否是我的mysql設置問題,總之,今天我在一開始使用的時候,如果不用commit,那數據就不會保留在資料庫中,但是,數據
確實在資料庫呆過.因為自動編號進行了累積,而且返回的受影響的行數並不為0.

6、關閉資料庫連接

需要分別的關閉指針對象和連接對象.他們有名字相同的方法
cursor.close()
conn.close()

Django操作資料庫
django是一個出色的用於python的web框架。django連接有操作資料庫的api，使用起來十分簡潔。我們在settings.py中配置好所要連接的資料庫，然後在moles、view、urls中分別寫好業務邏輯

⑹ 如何用python寫sql

python可以利用pymysql模塊操作資料庫。

什麼是 PyMySQL？

PyMySQL 是在 Python3.x 版本中用於連接 MySQL 伺服器的一個庫，Python2中則使用mysqldb。

PyMySQL 遵循 Python 資料庫 API v2.0 規范，並包含了 pure-Python MySQL 客戶端庫。

PyMySQL 安裝

在使用 PyMySQL 之前，我們需要確保 PyMySQL 已安裝。

PyMySQL 下載地址：https://github.com/PyMySQL/PyMySQL。

如果還未安裝，我們可以使用以下命令安裝最新版的 PyMySQL：

$ pip3 install PyMySQL

如果你的系統不支持 pip 命令，可以使用以下方式安裝：

1、使用 git 命令下載安裝包安裝(你也可以手動下載)：

$ git clone https://github.com/PyMySQL/PyMySQL$ cd PyMySQL/$ python3 setup.py install

2、如果需要制定版本號，可以使用 curl 命令來安裝：

$ # X.X 為 PyMySQL 的版本號$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz$ cd PyMySQL*$ python3 setup.py install
$ # 現在你可以刪除 PyMySQL* 目錄

注意：請確保您有root許可權來安裝上述模塊。

安裝的過程中可能會出現"ImportError: No mole named setuptools"的錯誤提示，意思是你沒有安裝setuptools，你可以訪問https://pypi.python.org/pypi/setuptools找到各個系統的安裝方法。

Linux 系統安裝實例：

$ wget https://bootstrap.pypa.io/ez_setup.py$ python3 ez_setup.py

資料庫連接

連接資料庫前，請先確認以下事項：

• 您已經創建了資料庫 TESTDB.

• 在TESTDB資料庫中您已經創建了表 EMPLOYEE

• EMPLOYEE表欄位為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。

• 連接資料庫TESTDB使用的用戶名為 "testuser" ，密碼為 "test123",你可以可以自己設定或者直接使用root用戶名及其密碼，Mysql資料庫用戶授權請使用Grant命令。

• 在你的機子上已經安裝了 Python MySQLdb 模塊。

• 如果您對sql語句不熟悉，可以訪問我們的SQL基礎教程

實例：

以下實例鏈接 Mysql 的 TESTDB 資料庫：

實例(Python 3.0+)

#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()
# 使用 execute() 方法執行 SQL 查詢 cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法獲取單條數據.data = cursor.fetchone()
print ("Database version : %s " % data)
# 關閉資料庫連接db.close()

執行以上腳本輸出結果如下：

• Database version : 5.5.20-log



創建資料庫表

如果資料庫連接存在我們可以使用execute()方法來為資料庫創建表，如下所示創建表EMPLOYEE：

實例(Python 3.0+)

#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()
# 使用 execute() 方法執行 SQL，如果表存在則刪除cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 使用預處理語句創建表sql = """CREATE TABLE EMPLOYEE (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql)
# 關閉資料庫連接db.close()

資料庫插入操作

以下實例使用執行 SQL INSERT 語句向表 EMPLOYEE 插入記錄：

實例(Python 3.0+)

#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 插入語句sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""try: # 執行sql語句
cursor.execute(sql)
# 提交到資料庫執行
db.commit()except: # 如果發生錯誤則回滾
db.rollback()
# 關閉資料庫連接db.close()

以上例子也可以寫成如下形式：

實例(Python 3.0+)

#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 插入語句sql = "INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('%s', '%s', %s, '%s', %s)" % ('Mac', 'Mohan', 20, 'M', 2000)try: # 執行sql語句
cursor.execute(sql)
# 執行sql語句
db.commit()except: # 發生錯誤時回滾
db.rollback()
# 關閉資料庫連接db.close()

以下代碼使用變數向SQL語句中傳遞參數:

• ..................................user_id = "test123"password = "password"con.execute('insert into Login values( %s, %s)' % (user_id, password))..................................



資料庫查詢操作

Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

• fetchone():該方法獲取下一個查詢結果集。結果集是一個對象

• fetchall():接收全部的返回結果行.

• rowcount:這是一個只讀屬性，並返回執行execute()方法後影響的行數。

實例：

查詢EMPLOYEE表中salary（工資）欄位大於1000的所有數據：

實例(Python 3.0+)

#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 查詢語句sql = "SELECT * FROM EMPLOYEE
WHERE INCOME > %s" % (1000)try: # 執行SQL語句
cursor.execute(sql)
# 獲取所有記錄列表
results = cursor.fetchall()
for row in results: fname = row[0]
lname = row[1]
age = row[2]
sex = row[3]
income = row[4]
# 列印結果
print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % (fname, lname, age, sex, income ))except: print ("Error: unable to fetch data")
# 關閉資料庫連接db.close()

以上腳本執行結果如下：

• fname=Mac, lname=Mohan, age=20, sex=M, income=2000



資料庫更新操作

更新操作用於更新數據表的的數據，以下實例將 TESTDB 表中 SEX 為 'M' 的 AGE 欄位遞增 1：

實例(Python 3.0+)

#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 更新語句sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')try: # 執行SQL語句
cursor.execute(sql)
# 提交到資料庫執行
db.commit()except: # 發生錯誤時回滾
db.rollback()
# 關閉資料庫連接db.close()

刪除操作

刪除操作用於刪除數據表中的數據，以下實例演示了刪除數據表 EMPLOYEE 中 AGE 大於 20 的所有數據：

實例(Python 3.0+)

#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 刪除語句sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)try: # 執行SQL語句
cursor.execute(sql)
# 提交修改
db.commit()except: # 發生錯誤時回滾
db.rollback()
# 關閉連接db.close()

執行事務

事務機制可以確保數據一致性。

事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。

• 原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要麼都做，要麼都不做。

• 一致性（consistency）。事務必須是使資料庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。

• 隔離性（isolation）。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的，並發執行的各個事務之間不能互相干擾。

• 持久性（rability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對資料庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。

實例

實例(Python 3.0+)

# SQL刪除記錄語句sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)try: # 執行SQL語句
cursor.execute(sql)
# 向資料庫提交
db.commit()except: # 發生錯誤時回滾
db.rollback()

對於支持事務的資料庫， 在Python資料庫編程中，當游標建立之時，就自動開始了一個隱形的資料庫事務。

commit()方法游標的所有更新操作，rollback（）方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務。

錯誤處理

DB API中定義了一些資料庫操作的錯誤及異常，下表列出了這些錯誤和異常:

異常

描述

Warning 當有嚴重警告時觸發，例如插入數據是被截斷等等。必須是 StandardError 的子類。

Error 警告以外所有其他錯誤類。必須是 StandardError 的子類。

InterfaceError 當有資料庫介面模塊本身的錯誤（而不是資料庫的錯誤）發生時觸發。 必須是Error的子類。

DatabaseError 和資料庫有關的錯誤發生時觸發。 必須是Error的子類。

DataError 當有數據處理時的錯誤發生時觸發，例如：除零錯誤，數據超范圍等等。 必須是DatabaseError的子類。

OperationalError 指非用戶控制的，而是操作資料庫時發生的錯誤。例如：連接意外斷開、 資料庫名未找到、事務處理失敗、內存分配錯誤等等操作資料庫是發生的錯誤。 必須是DatabaseError的子類。

IntegrityError 完整性相關的錯誤，例如外鍵檢查失敗等。必須是DatabaseError子類。

InternalError 資料庫的內部錯誤，例如游標（cursor）失效了、事務同步失敗等等。 必須是DatabaseError子類。

ProgrammingError 程序錯誤，例如數據表（table）沒找到或已存在、SQL語句語法錯誤、 參數數量錯誤等等。必須是DatabaseError的子類。

NotSupportedError 不支持錯誤，指使用了資料庫不支持的函數或API等。例如在連接對象上 使用.rollback()函數，然而資料庫並不支持事務或者事務已關閉。 必須是DatabaseError的子類。

⑺ python 向sql語句中傳參

一般的處理思路是將資料庫操作的方法放在一個模塊中，比如ConnectSQL.py：

importMySQLdb
defExecNonQuery(sql):
conn=MySQLdb.connect(host='xxxx',user='xxxx',passwd='xxxx',db='xxxx')
cur=conn.cursor()
cur.execute(sql)
conn.commit()
conn.close()

那麼你的a.py代碼為：

fromConnectSQLimport*
defmysql_insert(i,data):
try:
ExecNonQuery('insertintomytestvalues(%s,%s)'%(i,data))
except:
return0

你的b.py代碼不變。

⑻ python 字元串處理 SQL查詢語句

>>> base = """("%(k)s" = '%(v)s')"""
>>> print ' and '.join([base % dict(k=k, v=v) for k,v in dict(name='tim', email='[email protected]').items()])

("email" = '[email protected]') and ("name" = 'tim')
>>>

另外: 強烈建議不採用拼接字元串的方式定義SQL,而是採用參數

⑼ python 如何使用源生sql語句查詢有多個參數過濾的情況

用django的object就是為了快速開發。所以在設計之初就不允許復雜的查詢，復雜的業務邏輯。

如果你設計的復雜，直接用sql，再多復雜都可以支持。

@age這東西是存貯過程里用的吧。這里用不著。

在python里，直接通過格式化欄位串，組裝成SQL再通過MysqlDb的cursor傳遞過去，然後fetch就可以了。

你的前面那段代碼已經說的很明白了。你先看一看python的基本語法 。

⑽ python如何操作SQL語句

這里有個比較清楚的解答：
http://..com/question/262503775.html
但是你的是一個文本的話，就要稍微改一下咯
如果改成cx_Oracle的話，就是這樣的：
import
sys
import
cx_Oracle
import
os
class
handleDataBase:
def
__init__(self,user,passwd,server,sql):
self.user=user
self.passwd=passwd
self.server=server
self.sql=sql
self.conn
=
cx_Oracle.connect("%s/%s@%s"%(self.user,self.passwd,self.server))
def
selectDB(self):
cursor
=
self.conn.cursor()
cursor.execute("select
count(1)
from
search_item_08")
ret
=
cursor.fetchall()
cursor.close()
print
ret
return
ret
def
closeDB(self):
self.conn.close()
if
__name__
==
"__main__":
if
len(sys.argv)
<
4:
print
"Need
Arguments:
user
passwd
server"
sys.exit(1)
user=sys.argv[1]
passwd=sys.argv[2]
server=sys.argv[3]
#sql='select
count(1)
from
search_item_08;'
#注意這里要改
sql
=
open('a.sql','r').read()
#改成從文件讀取
#接下來就訪問資料庫了
handleDB
=
handleDataBase(user,passwd,server,sql)
handleDB.selectDB()
handleDB.closeDB()