æéç¨çæ¯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æ¡.
温馨提示:内容为网友见解,仅供参考