Selaa lähdekoodia

fix sql error

master
Jeong Geol Kim 4 vuotta sitten
vanhempi
commit
7f087dee75
1 muutettua tiedostoa jossa 3 lisäystä ja 1 poistoa
  1. 3
    1
      kpi.py

+ 3
- 1
kpi.py Näytä tiedosto

@@ -19,7 +19,7 @@ def put_kpi_to_db(kpi):
19 19
     conn = pymssql.connect(server='52.231.39.219',port=1433, user='mc365', password='tkadbrdhmc1!', database='master')
20 20
     
21 21
     cursor = conn.cursor()
22
-    cursor.execute("INSERT INTO tsfmc_mailsystem.dbo.KPI(surgeryID, totalStrokeCount, totalStrokeVelocity, totalStrokeDepth, upDownTotalStrokeCount, upDownTotalStrokeVelocity, upDownTotalStrokeDepth, leftRightTotalStrokeCount, leftRightTotalStrokeVelocity, leftRightTotalStrokeDepth, quadrant1TotalStrokeCount, quadrant1TotalStrokeVelocity, quadrant1TotalStrokeDepth, quadrant2TotalStrokeCount, quadrant2TotalStrokeVelocity, quadrant2TotalStrokeDepth, quadrant3TotalStrokeCount, quadrant3TotalStrokeVelocity, quadrant3TotalStrokeDepth, quadrant4TotalStrokeCount, quadrant4TotalStrokeVelocity, quadrant4TotalStrokeDepth) VALUES ("+str(kpi[0].values[0])+", "+str(kpi[1].values[0])+", "+str(kpi[2].values[0])+", "+str(kpi[3].values[0])+", "+str(kpi[4].values[0])+", "+str(kpi[5].values[0])+", "+str(kpi[6].values[0])+", "+str(kpi[7].values[0])+", "+str(kpi[8].values[0])+", "+str(kpi[9].values[0])+", "+str(kpi[10].values[0])+", "+str(kpi[11].values[0])+", "+str(kpi[12].values[0])+", "+str(kpi[13].values[0])+", "+str(kpi[14].values[0])+", "+str(kpi[15].values[0])+", "+str(kpi[16].values[0])+", "+str(kpi[17].values[0])+", "+str(kpi[18].values[0])+", "+str(kpi[19].values[0])+", "+str(kpi[20].values[0])+", "+str(kpi[21].values[0])+")")
22
+    cursor.execute("INSERT INTO tsfmc_mailsystem.dbo.KPI(surgeryID, totalStrokeCount, totalStrokeVelocity, totalStrokeDepth, upDownTotalStrokeCount, upDownTotalStrokeVelocity, upDownTotalStrokeDepth, leftRightTotalStrokeCount, leftRightTotalStrokeVelocity, leftRightTotalStrokeDepth, quadrant1TotalStrokeCount, quadrant1TotalStrokeVelocity, quadrant1TotalStrokeDepth, quadrant2TotalStrokeCount, quadrant2TotalStrokeVelocity, quadrant2TotalStrokeDepth, quadrant3TotalStrokeCount, quadrant3TotalStrokeVelocity, quadrant3TotalStrokeDepth, quadrant4TotalStrokeCount, quadrant4TotalStrokeVelocity, quadrant4TotalStrokeDepth) VALUES ("+str(kpi[0])+", "+str(kpi[1])+", "+str(kpi[2])+", "+str(kpi[3])+", "+str(kpi[4])+", "+str(kpi[5])+", "+str(kpi[6])+", "+str(kpi[7])+", "+str(kpi[8])+", "+str(kpi[9])+", "+str(kpi[10])+", "+str(kpi[11])+", "+str(kpi[12])+", "+str(kpi[13])+", "+str(kpi[14])+", "+str(kpi[15])+", "+str(kpi[16])+", "+str(kpi[17])+", "+str(kpi[18])+", "+str(kpi[19])+", "+str(kpi[20])+", "+str(kpi[21])+")")
23 23
     conn.commit()
24 24
     conn.close()
25 25
 
@@ -167,6 +167,7 @@ def dist():
167 167
     kpi['qaud2_d'] = quad2_c['sqrt'].mean() / 45
168 168
     kpi['qaud3_d'] = quad3_c['sqrt'].mean() / 45
169 169
     kpi['qaud4_d'] = quad4_c['sqrt'].mean() / 45
170
+    kpi = kpi.fillna(0)
170 171
 
171 172
 
172 173
     kpi_1 = {
@@ -228,5 +229,6 @@ def dist():
228 229
 if __name__ == "__main__":
229 230
     kpi = dist()
230 231
     kpi_csv = pd.DataFrame([kpi])
232
+    kpi = kpi_csv.fillna(0)
231 233
     kpi_csv.to_csv(os.path.join(file_path,'kpi.csv'))
232 234
     put_kpi_to_db(kpi)

Loading…
Peruuta
Tallenna