1. 程式人生 > >樹莓派安裝mysql資料庫並且通過python來進行儲存操作

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

具體的安裝資料庫的操作詳見:http://blog.csdn.net/huayucong/article/details/49736427

安裝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()