作者：笑不评j | 来源：互联网 | 2023-09-25 15:19
请教一些问题。
我做了一个网页，网页需要实时获取数据库的数据并返回显示到网页上，而数据库部分会在后台被另一个程序实时修改。
请问应该用什么方法来完成呢？
我现在写的代码如下：
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
| from flask import Flask,render_template,request
# import pymysql
from wtforms import form,Form
from wtforms.fields import simple
from DPT import DPT
app&＃061;Flask(__name__)
app.release&＃061;True
# app.config["SQLALCHEMY_DATABASE_URI"]&＃061;&＃039;mysql://root:yidaimingjvn2017&＃064;127.0.0.1/icms&＃039;
# db&＃061;SQLAlchemy(app)
dpt &＃061; DPT()
dpt.icms_connect()
id_area&＃061;dpt.id()
name_area&＃061;dpt.area_name()
time_area&＃061;dpt.area_time()
people_count&＃061;dpt.area_count()
&＃064;app.route(&＃039;/&＃039;,methods&＃061;["GET","POST"])
def index():
stop &＃061; 0
dpt.icms_close()
dpt.icms_connect()
return render_template("index.html",
id_area&＃061;id_area,
name_area&＃061;name_area,
time_area&＃061;time_area,
people_count&＃061;people_count,
form&＃061;form
)
if __name__ &＃061;&＃061; &＃039;__main__&＃039;:
app.run(host&＃061;"127.0.0.1", port&＃061;"80") |
DPT.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
| import pymysql
pymysql.install_as_MySQLdb()
class DPT:
def __init__(self):
self.conn&＃061; None
def icms_connect(self):
self.conn &＃061; pymysql.connect(host&＃061;"127.0.0.1", port&＃061;3306, user&＃061;"root", passwd&＃061;"yidaimingjvn2017", db&＃061;"icms" ,autocommit&＃061;True)
def icms_close(self):
self.cursor.close()
self.conn.close()
def sql_coursor(self):
self.cursor &＃061; self.conn.cursor(cursor&＃061;pymysql.cursors.DictCursor)
self.cursor.execute("select id,name,create_time from icms_address")
self.count_cursor &＃061; self.conn.cursor(cursor&＃061;pymysql.cursors.DictCursor)
self.count_cursor.execute("select count from icms_crowd_count")
def id(self):
"""获取记录条数"""
self.sql_coursor()
self.id_area &＃061; []
for self.area in self.cursor.fetchall():
self.id_area.append(self.area["id"])
return self.id_area
def area_name(self):
self.sql_coursor()
self.name_area &＃061; []
for self.name in self.cursor.fetchall():
self.name_area.append(self.name["name"])
return self.name_area
def area_time(self):
self.sql_coursor()
self.time_area &＃061; []
for self.time in self.cursor.fetchall():
self.time_area.append(self.time["create_time"])
return self.time_area
def area_count(self):
self.sql_coursor()
self.people_count &＃061; []
for self.count in self.count_cursor.fetchall():
self.people_count.append(self.count["count"])
return self.people_count
# dpt&＃061;DPT()
# dpt.icms_connect()
# while 1:
# print(dpt.area_count()) |
HTML部分：
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
| {% if 0 &＃061;&＃061; stop %} {% endif %}
人群管理系统 |
|---|
{% for num in id_area %}
![]() |
地点&＃xff1a; {{ name_area[num-1] }} 人数&＃xff1a;
{{ people_count[num-1] }}
时间&＃xff1a;{{ time_area[num-1] }}
|
|
{% endfor %}
|
京公网安备 11010802041100号