- 1、python專業版本上如何直接創建數據庫
- 2、如何在python中進行數據庫的添加
- 3、如何創建自己的python包
- 4、Python該怎麼入門?
- 5、python 怎麼創建create mysql的數據庫
- 6、如何用python創建數據庫
import pymysql
# 打開數據庫
db = pymysql.connect(host=’localhost’, port=3306, user=’root’, passwd=’root’, db=’lianxi’, charset=’utf8′)
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# 如果數據表已經存在使用execute()方法刪除表
cursor.execute(“drop table if EXISTS income”)
# 創建數據庫SQL語句
# time,ironincome,general_income,baiincome
SQL = “””CREATE TABLE `income` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`datetime` varchar(20) DEFAULT NULL,
`ironincome` decimal(20,2) DEFAULT NULL,
`generalincome` decimal(20,2) DEFAULT NULL,
`baiincome` decimal(20,2) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
“””
cursor.execute(SQL)
db.close()
你可以訪問Python數據庫接口及API查看詳細的支持數據庫列表。不同的數據庫你需要下載不同的DB API模塊，例如你需要訪問Oracle數據庫和Mysql數據，你需要下載Oracle和MySQL數據庫模塊。
DB-API 是一個規範. 它定義了一系列必須的對象和數據庫存取方式, 以便為各種各樣的底層數據庫系統和多種多樣的數據庫接口程序提供一致的訪問接口 。
Python的DB-API，為大多數的數據庫實現了接口，使用它連接各數據庫後，就可以用相同的方式操作各數據庫。
Python DB-API使用流程：
引入 API 模塊。
獲取與數據庫的連接。
執行SQL語句和存儲過程。
關閉數據庫連接。
什麼是MySQLdb?
MySQLdb 是用於Python鏈接Mysql數據庫的接口，它實現了 Python 數據庫 API 規範 V2.0，基於 MySQL C API 上建立的。
如何安裝MySQLdb?
為了用DB-API編寫MySQL腳本，必須確保已經安裝了MySQL。複製以下代碼，並執行：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
如果執行後的輸出結果如下所示，意味着你沒有安裝 MySQLdb 模塊：
Traceback (most recent call last):
File “test.py”, line 3, in module
import MySQLdb
ImportError: No module named MySQLdb
安裝MySQLdb，請訪問 ，(Linux平台可以訪問：)從這裡可選擇適合您的平台的安裝包，分為預編譯的二進制文件和源代碼安裝包。
如果您選擇二進制文件發行版本的話，安裝過程基本安裝提示即可完成。如果從源代碼進行安裝的話，則需要切換到MySQLdb發行版本的頂級目錄，並鍵入下列命令:
$ gunzip MySQL-python-1.2.2.tar.gz
$ tar -xvf MySQL-python-1.2.2.tar
$ cd MySQL-python-1.2.2
$ python setup.py build
$ python setup.py install
注意：請確保您有root權限來安裝上述模塊。
數據庫連接
連接數據庫前，請先確認以下事項：
您已經創建了數據庫 TESTDB.
在TESTDB數據庫中您已經創建了表 EMPLOYEE
EMPLOYEE表字段為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
連接數據庫TESTDB使用的用戶名為 “testuser” ，密碼為 “test123”,你可以可以自己設定或者直接使用root用戶名及其密碼，Mysql數據庫用戶授權請使用Grant命令。
在你的機子上已經安裝了 Python MySQLdb 模塊。
如果您對sql語句不熟悉，可以訪問我們的 SQL基礎教程
實例：
以下實例鏈接Mysql的TESTDB數據庫：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# 使用execute方法執行SQL語句
cursor.execute(“SELECT VERSION()”)
# 使用 fetchone() 方法獲取一條數據庫。
data = cursor.fetchone()
print “Database version : %s ” % data
# 關閉數據庫連接
db.close()
執行以上腳本輸出結果如下：
Database version : 5.0.45
創建數據庫表
如果數據庫連接存在我們可以使用execute()方法來為數據庫創建表，如下所示創建表EMPLOYEE：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# 如果數據表已經存在使用 execute() 方法刪除表。
cursor.execute(“DROP TABLE IF EXISTS EMPLOYEE”)
# 創建數據表SQL語句
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 插入記錄：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.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:
# Rollback in case there is any error
db.rollback()
# 關閉數據庫連接
db.close()
以上例子也可以寫成如下形式：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 插入語句
sql = “INSERT INTO EMPLOYEE(FIRST_NAME, \
LAST_NAME, AGE, SEX, INCOME) \
VALUES (‘%s’, ‘%s’, ‘%d’, ‘%c’, ‘%d’ )” % \
(‘Mac’, ‘Mohan’, 20, ‘M’, 2000)
try:
# 執行sql語句
cursor.execute(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的所有數據：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 查詢語句
sql = “SELECT * FROM EMPLOYEE \
WHERE INCOME ‘%d'” % (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=%d,sex=%s,income=%d” % \
(fname, lname, age, sex, income )
except:
print “Error: unable to fecth data”
# 關閉數據庫連接
db.close()
以上腳本執行結果如下：
fname=Mac, lname=Mohan, age=20, sex=M, income=2000
數據庫更新操作
更新操作用於更新數據表的的數據，以下實例將 TESTDB表中的 SEX 字段全部修改為 ‘M’，AGE 字段遞增1：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.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 的所有數據：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 刪除語句
sql = “DELETE FROM EMPLOYEE WHERE AGE ‘%d'” % (20)
try:
# 執行SQL語句
cursor.execute(sql)
# 提交修改
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
# 關閉連接
db.close()
執行事務
事務機制可以確保數據一致性。
事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。
原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要麼都做，要麼都不做。
一致性（consistency）。事務必須是使數據庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。
隔離性（isolation）。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的，並發執行的各個事務之間不能互相干擾。
持久性（durability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。
Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。
用distutils製作自己的安裝包
看下面的例子：
mylib.py 文件
def add(x,y):
return x+y
def division(x,y):
return x/y
def mutiply(x,y):
return x*y
def subtract(x,y):
return x-y
def main():
pass
if __name__ == ‘__main__’:
main()
簡單的方法可以進入到mylib.py存放的目錄，然後import mylib就可以使用它提供的方法了。但是如果項目比較大，需要很多人協作的話，這樣就非常不方便。這時候可以使用distutils標準庫。於是我們可以在mylib.py同級目錄下再創建一個setup.py，它的內容如下：
from distutils.core import setup
setup(name=’mylib’,
version=’1.0′,
py_modules=[‘mylib’],
)
name是指定的包名，version是版本號，py_modules里包含需要安裝的python文件，本例中即為mylib.py文件。
編寫好setup.py後，就可以使用
python setup.py install
把它安裝到系統中了。
要把自己的安裝包上傳到PyPI上，從而像其他安裝包一樣可以試用easy_install 或 pip安裝的話，就需要遵循PEP241，給出足夠的元數據才行，比如對包的描述，作者的信息，授權方式，主頁等，具體的可以查詢文檔。
作為初學者，第一個月的月目標應該是這樣的：
熟悉基本概念（變量，條件，列表，循環，函數）
練習超過 30 個編程問題
利用這些概念完成兩個項目
熟悉至少 2 個框架
開始使用集成開發環境（IDE），Github，hosting，services 等
整體計劃
現在，我們先將月計劃細化成周計劃。
第一周：熟悉 Python
要積極探索 Python 的使用方法，儘可能多的完成下面這些任務：
第一天：基本概念（4 小時）：print，變量，輸入，條件語句
第二天：基本概念（5 小時）：列表，for 循環，while 循環，函數，導入模塊
第三天：簡單編程問題（5 小時）：交換兩個變量值，將攝氏度轉換為華氏溫度，求數字中各位數之和，判斷某數是否為素數，生成隨機數，刪除列表中的重複項等等
第四天：中級編程問題（6 小時）：反轉一個字符串（迴文檢測），計算最大公約數，合併兩個有序數組，猜數字遊戲，計算年齡等等
第五天：數據結構（6 小時）：棧，隊列，字典，元組，樹，鏈表。
第六天：面向對象編程（OOP）（6 小時）：對象，類，方法和構造函數，面向對象編程之繼承
第七天：算法（6 小時）：搜索（線性和二分查找）、排序（冒泡排序、選擇排序）、遞歸函數（階乘、斐波那契數列）、時間複雜度（線性、二次和常量）
通過第一周時間，python大致能熟悉了，自學能力稍微弱一點找人帶下你，節約自己的時間。
注意：別急着安裝 Python 環境！
這看起來很矛盾，但是你一定要相信我。我有幾個朋友，他們因為語言工具包和 IDE 安裝的失敗而逐漸失去了學習下去的慾望。因此，我的建議是先使用一些安卓 app 來探索這門語言，如果你是個技術小白，安裝 Python 環境可不是你的首要任務。
第二周：開始軟件開發（構建項目）
接下來，讓我們朝着軟件開發任務進軍吧！不妨嘗試綜合你學到的知識完成一個實際的項目：
第一天：熟悉一種 IDE（5 小時）: IDE 是你在編寫大型項目時的操作環境，所以你需要精通一個 IDE。在軟件開發的初期，我建議你在 VS code 中安裝 Python 擴展或使用 Jupyter notebook。
第二天：Github（6 小時）：探索 Github，並創建一個代碼倉庫。嘗試提交（Commit）、查看變更（Diff）和上推（Push）你的代碼。另外，還要學習如何利用分支工作，如何合併（merge）不同分支以及如何在一個項目中創建拉取請求（pull request）。
第三天：第一個項目——簡單計算器（4 小時）：熟悉 Tkinter，創建一個簡單的計算器
第四、五、六天：個人項目（每天 5 小時）：選定一個項目並完成它。如果你不知道你該做什麼，可以查看下面的清單（ pythonprojects -for-an- middle – programmer/answer/jhankar – mahbub2）
第七天：託管項目（5 小時）：學習使用服務器和 hosting 服務來託管你的項目。創建一個 Heroku 設置並部署你構建的應用程序。
為什麼要寫項目？
如果僅僅按部就班地學習課堂上或視頻中的內容，你無法擁有獨立思考能力。所以，你必須把你的知識應用到一個項目中。當你努力尋找答案時，你也在慢慢地學會這些知識。
第三周：讓自己成為一名程序員
第 3 周的目標是熟悉軟件開發的整體過程。你不需要掌握所有的知識，但是你應該知道一些常識，因為它們會影響你的日常工作。
第一天：數據庫基礎（6 小時）：基本 SQL 查詢（創建表、選擇、Where 查詢、更新）、SQL 函數（Avg、Max、Count）、關係數據庫（規範化）、內連接、外連接等
第二天：使用 Python 數據庫（5 小時）：利用一種數據庫框架（SQLite 或 panda），連接到一個數據庫，在多個表中創建並插入數據，再從表中讀取數據。
第三天：API（5 小時）：如何調用 API。學習 JSON、微服務（micro-service）以及表現層應用程序轉換應用程序接口（Rest API）。
第四天：Numpy（4 小時）：熟悉 Numpy（- Numpy -for- datascies-beginners-b8088722309f）並練習前 30 個 Numpy 習題（- 100/blob/master/100_numpy_excercises.md)
第五、六天：作品集網站（一天 5 小時）：學習 Django，使用 Django 構建一個作品集網站（- start-with-django -1/），也要了解一下 Flask 框架。
第七天：單元測試、日誌、調試（5 小時）：學習單元測試（PyTest），如何設置和查看日誌，以及使用斷點調試。
真心話時間（絕密）
如果你非常「瘋狂」，並且非常專註，你可以在一個月內完成這些任務。你必須做到：
把學習 Python 作為你的全職活動。你需要從早上 8 點開始學習，一直到下午 5 點。在此期間，你可以有一個午休時間和茶歇時間（共 1 小時）。
8 點列出你今天要學的東西，然後花一個小時複習和練習你昨天學過的東西。
從 9 點到 12 點：開始學習，並進行少量練習。在午飯後，你需要加大練習量，如果你卡在某個問題上，可以在網上搜索解決方案。
嚴格保持每天 4-5 小時的學習時間和 2-3 小時的練習時間（每周最多可以休息一天）。
你的朋友可能會認為你瘋了。走自己的路，讓別人去說吧！
如果你有一份全職工作，或者你是一名學生，完成這些流程可能需要更長的時間。作為一名全日制學生，我花了 8 個月的時間來完成這份清單。現在我是一名高級開發人員。所以，不管花多長時間，一定要完成它們。要想成功完成一個目標，必須付出百分之百的努力。
第四周：認真考慮工作（實習）問題
第 4 周的目標是認真思考如何才能被錄用。即使你現在不想找工作，你也可以在探索這條道路的過程中學到很多東西。
第一天：準備簡歷（5 小時）：製作一份一頁的簡歷。把你的技能總結放在最上面，必須在寫項目的同時附上 Github 鏈接。
第二天：作品集網站（6 小時）：寫幾個博客，將它們添加到你之前開發的作品集網站中。
第三天：LinkedIn 簡介（4 小時）：創建一個 LinkedIn 個人簡介，把簡歷上的所有內容都放到 LinkedIn 上。
第四天：面試準備（7 小時）：準備一些谷歌常見的面試問題，練習白皮書中的 10 個面試編程問題。在 Glassdoor、Careercup 等網站中查看前人遇到的面試問題。
第五天：社交（~小時）：走出房門，開始參加聚會、招聘會，與其他開發人員和招聘人員見面。
第六天：工作申請（~小時）：搜索「Python Job」，查看 LinkedIn Job 和本地求職網站。選擇 3 個工作崗位並發送工作申請。為每個工作定製你的簡歷。在每個工作要求中找出 2 到 3 件你不知道的事情，並在接下來的 3-4 天里學會它們。
第七天：在拒絕中學習（~小時）：每次你被拒絕的時候，找出兩件為了獲得這份工作你應該知道的事情，然後花 4-5 天 的時間來掌握它們。這樣，每次拒絕都會讓你成為更好的開發人員。
我採用的是MySQLdb操作的MYSQL數據庫。先來一個簡單的例子吧：
import MySQLdb
try:
conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,db=’test’,port=3306)
cur=conn.cursor()
cur.execute(‘select * from user’)
cur.close()
conn.close()
except MySQLdb.Error,e:
print “Mysql Error %d: %s” % (e.args[0], e.args[1])
請注意修改你的數據庫，主機名，用戶名，密碼。
下面來大致演示一下插入數據，批量插入數據，更新數據的例子吧：
import MySQLdb
try:
conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,port=3306)
cur=conn.cursor()
cur.execute(‘create database if not exists python’)
conn.select_db(‘python’)
cur.execute(‘create table test(id int,info varchar(20))’)
value=[1,’hi rollen’]
cur.execute(‘insert into test values(%s,%s)’,value)
values=[]
for i in range(20):
values.append((i,’hi rollen’+str(i)))
cur.executemany(‘insert into test values(%s,%s)’,values)
cur.execute(‘update test set info=”I am rollen” where id=3’)
conn.commit()
cur.close()
conn.close()
except MySQLdb.Error,e:
print “Mysql Error %d: %s” % (e.args[0], e.args[1])
請注意一定要有conn.commit()這句來提交事務，要不然不能真正的插入數據。
運行之後我的MySQL數據庫的結果就不上圖了。
import MySQLdb
try:
conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,port=3306)
cur=conn.cursor()
conn.select_db(‘python’)
count=cur.execute(‘select * from test’)
print ‘there has %s rows record’ % count
result=cur.fetchone()
print result
print ‘ID: %s info %s’ % result
results=cur.fetchmany(5)
for r in results:
print r
print ‘==’*10
cur.scroll(0,mode=’absolute’)
results=cur.fetchall()
for r in results:
print r[1]
conn.commit()
cur.close()
conn.close()
except MySQLdb.Error,e:
print “Mysql Error %d: %s” % (e.args[0], e.args[1])
運行結果就不貼了，太長了。
查詢後中文會正確顯示，但在數據庫中卻是亂碼的。經過我從網上查找，發現用一個屬性有可搞定：
在Python代碼
conn = MySQLdb.Connect(host=’localhost’, user=’root’, passwd=’root’, db=’python’) 中加一個屬性：
改為：
conn = MySQLdb.Connect(host=’localhost’, user=’root’, passwd=’root’, db=’python’,charset=’utf8′)
charset是要跟你數據庫的編碼一樣，如果是數據庫是gb2312 ,則寫charset=’gb2312’。
下面貼一下常用的函數：
然後,這個連接對象也提供了對事務操作的支持,標準的方法
commit() 提交
rollback() 回滾
cursor用來執行命令的方法:
callproc(self, procname, args):用來執行存儲過程,接收的參數為存儲過程名和參數列表,返回值為受影響的行數
execute(self, query, args):執行單條sql語句,接收的參數為sql語句本身和使用的參數列表,返回值為受影響的行數
executemany(self, query, args):執行單挑sql語句,但是重複執行參數列表裡的參數,返回值為受影響的行數
nextset(self):移動到下一個結果集
cursor用來接收返回值的方法:
fetchall(self):接收全部的返回結果行.
fetchmany(self, size=None):接收size條返回結果行.如果size的值大於返回的結果行的數量,則會返回cursor.arraysize條數據.
fetchone(self):返回一條結果行.
scroll(self, value, mode=’relative’):移動指針到某一行.如果mode=’relative’,則表示從當前所在行移動value條,如果 mode=’absolute’,則表示從結果集的第一行移動value條.
參考資料：
MySQLdb『s user guide
package MySQLdb
通過以下的內容你就可以輕鬆的運用Python數據庫連接池的相關步驟，希望下面的文章會對你有所收穫。 請求連接： 1. db＝pool．connection（）2. 你可以使用這些連接有如原始的DB－API 2一樣。而實際使用的是“SteadyDB“版本的強硬連接。請注意連接可以與其他線程共享，只要你設置 maxshared 參數為非零，並且DB－API 2模塊也允許。如果你想要使用專用連接則使用： 1. db＝pool．connection（0）2. 如果你不再需要這個連接了，則可以返回給連接池使用 db．close（）。你也可以使用相同的方法獲取另一個連接。警告：在一個多線程環境，不要使用下面的方法： 1. pool．connection（）．cursor（）．execute（．．．）2. 3. db＝pool．connection（）4. 5. cur＝db．cursor（）6. 7. cur．execute（．．．）8. 9. res＝cur．fetchone（）10. 11. cur．close（） # or del cur12. 13. db．close（） # or del db14. 示例 [方便你將來直接使用] 使用PersistentDB 模塊 1. import threading，time，datetime2. 3. import MySQLdb4. 5. import DBUtils．PersistentDB6. 7. persist＝DBUtils．PersistentDB．PersistentDB（MySQLdb，100，host＝’localhost’，user＝’root’，passwd＝’321’，db＝’test’，charset＝’utf8’）8. 9. conn＝persist．connection（）10. 11. cursor＝conn．cursor（）12. 13. cursor．execute（”insert into me values（1，’22222’）”）14. 15. conn．commit（）16. 17. conn．close（）18. 通過以上的內容你就可以得到數據庫連接了！ 作者：不詳 來源：網絡
原創文章，作者：簡單一點，如若轉載，請註明出處：https://www.506064.com/zh-hk/n/126747.html
微信掃一掃 
支付寶掃一掃 
