樹莓派安裝mysql資料庫并且通過python來進行存儲操作

安裝python-Mysqldb

安裝完成後，加上我之前有一片的溫濕度監測的代碼：

（mysql資料庫在樹莓派上；

使用者名密碼：root，123456；

端口：3306；

位址：localhost或者127.0.0.1；

資料庫：testdb；

表：temp；

列名：time，temperature，humidity）

建立資料庫和表的代碼沒寫進去，可以在外面建立或者寫在裡面。個人建議是寫在外面。

import RPi.GPIO as GPIO
import time
import MySQLdb
import os


#print time.time()
aa=time.strftime('%m%d%H%I%M',time.localtime(time.time()))
print aa
bb=int(aa)
#print (type(bb))
channel = 16
data = []
j = 0

GPIO.setmode(GPIO.BCM)

time.sleep(1)

GPIO.setup(channel, GPIO.OUT)

GPIO.output(channel, GPIO.LOW)
time.sleep(0.02)
GPIO.output(channel, GPIO.HIGH)

GPIO.setup(channel, GPIO.IN)

while GPIO.input(channel) == GPIO.LOW:
        continue

while GPIO.input(channel) == GPIO.HIGH:
        continue

while j < 40:
        k = 0
        while GPIO.input(channel) == GPIO.LOW:
                continue

        while GPIO.input(channel) == GPIO.HIGH:
                k += 1
                if k > 100:
                        break

        if k < 8:
                data.append(0)
        else:
                data.append(1)

        j += 1

print "sensor is working."
print data
humidity_bit = data[0:8]
humidity_point_bit = data[8:16]
temperature_bit = data[16:24]
temperature_point_bit = data[24:32]
check_bit = data[32:40]

humidity = 0
humidity_point = 0
temperature = 0
temperature_point = 0
check = 0

for i in range(8):
        humidity += humidity_bit[i] * 2 ** (7 - i)
        humidity_point += humidity_point_bit[i] * 2 ** (7 - i)
        temperature += temperature_bit[i] * 2 ** (7 - i)
        temperature_point += temperature_point_bit[i] * 2 ** (7 - i)
        check += check_bit[i] * 2 ** (7 - i)

tmp = humidity + humidity_point + temperature + temperature_point

if check == tmp:
        print "temperature : ", temperature, ", humidity : " , humidity
        conn= MySQLdb.connect(
                host='127.0.0.1',
                port = 3306,
                user='root',
                passwd='123456',
                db ='testdb',
                )
        cur = conn.cursor()
        # cur.execute("creat table if not exists temp(time int,temperature int,humidity int)")
        cur.execute("insert into temp values('%d','%d','%d')"%(bb,temperature,humidity))
        cur.close()
        conn.commit()
        conn.close()
else:
        print "wrong"
        print "temperature : ", temperature, ", humidity : " , humidity, " check : ", check, " tmp : ", tmp
GPIO.cleanup()