init
This commit is contained in:
@@ -1,4 +1,5 @@
|
|||||||
import os
|
import os
|
||||||
|
import time
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
|
|
||||||
from hts.HTS import HTS
|
from hts.HTS import HTS
|
||||||
@@ -83,6 +84,6 @@ if __name__ == "__main__":
|
|||||||
this_day = this_day + timedelta(days=1)
|
this_day = this_day + timedelta(days=1)
|
||||||
if this_day > stock["end_date"]:
|
if this_day > stock["end_date"]:
|
||||||
break
|
break
|
||||||
|
time.sleep(0.5)
|
||||||
hts.disconnect()
|
hts.disconnect()
|
||||||
print ("done...")
|
print ("done...")
|
||||||
|
|||||||
@@ -493,7 +493,6 @@ class HTS:
|
|||||||
self.cursor.execute('DELETE FROM hts WHERE CODE=? and ymd=? and hms=?', (stock_code, ymd, hms,))
|
self.cursor.execute('DELETE FROM hts WHERE CODE=? and ymd=? and hms=?', (stock_code, ymd, hms,))
|
||||||
self.cursor.execute("INSERT INTO hts (CODE, NAME, ymd, hms, close, open, high, low, volume) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?)", (stock_code, stock_name, ymd, hms, close, open, high, low, volume))
|
self.cursor.execute("INSERT INTO hts (CODE, NAME, ymd, hms, close, open, high, low, volume) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?)", (stock_code, stock_name, ymd, hms, close, open, high, low, volume))
|
||||||
|
|
||||||
time.sleep(0.5)
|
|
||||||
self.conn.commit()
|
self.conn.commit()
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user