關於python定時查詢數據庫的信息

本文目錄一覽：

• 1、如何在數據庫中數據達到特定條件執行外部腳本？比如python
• 2、如何使用python連接數據庫，插入並查詢數據
• 3、python腳本怎麼把實時數據記錄下來
• 4、python 微信怎麼查詢數據庫表內所有內容
• 5、如何用python操作數據庫表

如何在數據庫中數據達到特定條件執行外部腳本？比如python

如何在數據庫中數據達到特定條件執行外部腳本？

1.不修改數據庫與系統結構，使用Python做個定時策略，每隔一段時間來執行【特定條件是否達到】的統計SQL腳本。這種模式適用於數據量不多，或者每次執行的統計腳本時間短，或者實時性要求低的情況。

2.修改數據庫，不改系統結構。那就是使用數據庫的觸發器，或者存儲過程，來充當抽象接口。通過抽象接口，來進行實時統計，但這樣做，壓力就集中在數據庫這邊，而且隨着數據量的增長，這種依賴於數據庫本身功能的結構，不容易優化。

3.同時修改數據庫與系統結構，用編程語言比如Python來寫中間件，進行實時統計，並把統計結果保存到數據庫。這就讓壓力轉移到中間件上，而且隨着數據量的增大，很容易把中間件做成多節點的集群模式來分擔壓力。

如何使用python連接數據庫，插入並查詢數據

python3.2 == ORM(或者數據庫接口) == 數據庫數據庫:PostgreSQL9、SQLite3等ORM:SQLAlchemy(需要安裝數據庫接口)數據庫接口:psycopg2(PostgreSQL9)建議使用ORM樣創建、修改、刪除時只涉及python類對象無需寫sql語句修改了數據表結構時對程序修改也方便些表間關係特別複雜也ORM直接寫sql語句

python腳本怎麼把實時數據記錄下來

1.不修改數據庫與系統結構，使用Python做個定時策略，每隔一段時間來執行【特定條件是否達到】的統計SQL腳本。這種模式適用於數據量不多，或者每次執行的統計腳本時間短，或者實時性要求低的情況。 2.修改數據庫，不改系統結構。那就是使用數據…

python 微信怎麼查詢數據庫表內所有內容

我常用pymssql連接M$SQL服務器, 沒用過pyodbc, 但按理應該都差不多。

若用pymssql, 從數據庫中取數據的過程如下:

import pymssql

connect_setting = {

‘host’: ‘127.0.0.1’,

‘user’: ‘sa’,

‘password’: ”,

‘database’: ‘master’,

‘charset’: ‘gb18030’

}

conn = pymssql.connect(**connect_setting)

curr = conn.cursor()

curr.execute(“select list, name from nlist”)

result = [(lst, name) for lst, name in curr]

curr.close()

conn.close()

關於”如何查詢,list的每個值在數據庫中對應的Name“

若庫表中的數據像下面的樣子:

id, name:

1, ‘python’

2, ‘perl’

3, ‘c’

4, ‘java’

且每行id是唯一值, 將從數據庫表中拿到的數據放到一個字典中:

curr.execute(“select id, name from nlist”)

dd = dict([(id, name) for id, name in curr])

lst = [1,2,3,4,5,6]

用dd進行轉換

[(i, dd.get(i)) for i in lst]

==

[(1, ‘python’), (2, ‘perl’), (3, ‘c’), (4, ‘java’), (5, None), (6, None)]

or

[dd.get(i, i) for i in lst]

==

[‘python’, ‘perl’, ‘c’, ‘java’, 5, 6]

如何用python操作數據庫表

# -*- coding:utf8 -*-

import MySQLdb

conn = MySQLdb.connect(                        #此處連接數據庫信息

host = ‘127.0.0.1’,

port = 3306,

user = ‘root’,

passwd = ‘root’,

db = ‘python’,

charset = ‘utf8’

)

key1 = raw_input()

value2 = raw_input()

cursor = conn.cursor()

try:

#cursor.execute(‘SELECT * from test’)  # 查詢數據庫內容

#print cursor.rowcount     #輸出改變行數

cursor.execute(“insert into test (‘key1’) values (value2)”)  # 增加數據庫內容

#cursor.execute(“update test set name = ‘lisi’ where name = ‘zhangsan'”)   # 更新數據庫內容

#cursor.execute(“delete from test where name = ‘lisi'”)  #刪除數據庫內容

conn.commit()

except Exception as e: # 執行出錯回滾數據

print e

conn.rollback()

cursor.close

conn.close