-
Notifications
You must be signed in to change notification settings - Fork 0
/
fedratedmysql.py
147 lines (104 loc) · 4.15 KB
/
fedratedmysql.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
import time
import board
import busio
#import time
import sys
import sqlite3
#from time import sleep
#import adafruit_ads1x15.ads1015 as ADS
import adafruit_ads1x15.ads1115 as ADS
from adafruit_ads1x15.analog_in import AnalogIn
import MySQLdb as db
#import mysql.connector
conn = db.connect(
host="localhost",
user="yogi",
passwd="bittoo",
database="flowrates"
)
'''
conn = db.connect(host="localhost",
user="yogi",
passwd="bittoo",
db="TemaccessToRemoteRp2")
'''
c = conn.cursor()
#print (conn)
#c.execute('DROP TABLE IF EXISTS temSensor;')
#print ('table deleted')
#c.execute("CREATE TABLE temSensor2(id INT AUTO_INCREMENT PRIMARY KEY, Temp1d4 FLOAT, Temp2d5 FLOAT, Temp3d6 FLOAT,\
#Temp4d13 FLOAT, Temp5d19 FLOAT, Temp6d26 FLOAT, Temp7d21 FLOAT,Temp8d20 FLOAT,Temp9d16 FLOAT, Temp10d12 FLOAT,\
#Temp11d1 FLOAT,Temp12d7 FLOAT, Temp13d8 FLOAT,Temp14d24 FLOAT, \
#Temp15d23 FLOAT, Temp16d18 FLOAT,Temp17d15 FLOAT, Temp18d14 FLOAT,Temp19d2 FLOAT,Date DATE,Time TIME, flowHp FLOAT, flowLoad FLOAT);")
'''
c.execute("SELECT * from temSensor")
result = c.fetchall()
for item in result:
print (item)
'''
#conn = sqlite3.connect('FlowSensors.db')
#c = conn.cursor()
date=time.strftime("%Y-%m-%d ")
t=time.strftime("%H:%M:%S")
# Create the I2C bus
i2c = busio.I2C(board.SCL, board.SDA)
# Create the ADC object using the I2C bus
ads = ADS.ADS1115(i2c)
ads.gain = 1
# Create single-ended input on channel 0
#chan = AnalogIn(ads, ADS.P0, ADS.P1)
chan1 = AnalogIn(ads, ADS.P0)
chan2 = AnalogIn(ads, ADS.P1)
#print (chan.value)
#print (chan.voltage)
#Create differential input between channel 0 and 1
#chan = AnalogIn(ads, ADS.P0, ADS.P1)
#print (chan.value, chan.voltage)
#print("{:>5}\t{:>5}".format('raw', 'v'))
#c.execute('DROP TABLE IF EXISTS flowReadings;')
#print ('table deleted')
c.execute('DROP TABLE IF EXISTS FrHpL;')
print ('table deleted')
c.execute('CREATE TABLE FrHpL(id INT NOT NULL AUTO_INCREMENT, flowHp FLOAT, \
flowLoad FLOAT, Date DATE,Time TIME, PRIMARY KEY (id) ) ENGINE=MyISAM;')
conn.commit()
#ALTER TABLE FrHpL ADD PRIMARY KEY (id) AFTER Time;
#c.execute('ALTER TABLE temSensor ADD flowHp FLOAT AFTER Time;')
#c.execute('ALTER TABLE temSensor ADD flowLoad FLOAT AFTER flowHp;')
#c.execute('IF NOT EXISTS (SELECT * FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = temSensor AND COLUMN_NAME = flowLoad ) \
#ALTER TABLE temSensor ADD flowLoad Float;')
#conn.commit()
while True:
#c.execute("INSERT INTO temSensor(flowHp, flowLoad, Date,Time) VALUES(?,?,?,?)", (chan2.voltage, chan1.voltage, date,t))
c.execute("INSERT INTO FrHpL(flowHp, flowLoad, Date, Time) VALUES(%s,%s, %s, %s)", (chan2.voltage, chan1.voltage, date,t))
conn.commit()
c.execute("SELECT * from FrHpL")
result = c.fetchall()
for item in result:
print (item)
#print('flow HP:',"{:>5}\t{:>5.3f}".format(chan2.value, chan2.voltage), '\n\n')
#print('flow load:',"{:>5}\t{:>5.3f}".format(chan1.value, chan1.voltage, '\n\n'))
print('________________________________________________________________')
#print("{:>5.3f}".format(chan.voltage))
time.sleep(1)
'''
while True:
#c.execute("INSERT INTO temSensor(flowHp, flowLoad, Date,Time) VALUES(?,?,?,?)", (chan2.voltage, chan1.voltage, date,t))
c.execute("INSERT INTO FrHpL(flowHp, flowLoad) VALUES(%s,%s)", (chan2.voltage, chan1.voltage))
conn.commit()
#print('flow HP:',"{:>5}\t{:>5.3f}".format(chan2.value, chan2.voltage), '\n\n')
#print('flow load:',"{:>5}\t{:>5.3f}".format(chan1.value, chan1.voltage, '\n\n'))
print('________________________________________________________________')
#print("{:>5.3f}".format(chan.voltage))
time.sleep(0.5)
'''
'''
while True:
#c.execute("INSERT INTO temSensor(flowHp, flowLoad, Date,Time) VALUES(?,?,?,?)", (chan2.voltage, chan1.voltage, date,t))
conn.commit()
print('flow HP:',"{:>5}\t{:>5.3f}".format(chan2.value, chan2.voltage), '\n\n')
print('flow load:',"{:>5}\t{:>5.3f}".format(chan1.value, chan1.voltage, '\n\n'))
print('________________________________________________________________')
#print("{:>5.3f}".format(chan.voltage))
time.sleep(0.5)
'''