import datetime
import pymysql
class DBUtil:
config = {
"host":"localhost",
"user":"root",
"password":"19950127",
"db":"development_load_prediction",
"charset":"utf8"
}
def __init__(self):
self.connection = pymysql.connect(**DBUtil.config)
self.cursor = self.connection.cursor()
def close(self):
if self.cursor:
self.cursor.close()
if self.connection:
self.connection.close()
#插入、修改、删除
def exeDML(self,sql,*args):
try:
#执行sql
count = self.cursor.execute(sql,args)
#提交事务
self.connection.commit()
return count
except Exception as e:
print(e)
if self.connection:
self.connection.rollback()
finally:
#self.close()
pass
#查询某行
def query_one(self,sql,*args):
try:
#执行sql
self.cursor.execute(sql,args)
#获取结果集
return self.cursor.fetchone()
except Exception as e:
print(e)
finally:
self.close()
#查询全部
def query_all(self,sql,*args):
try:
#执行sql
self.cursor.execute(sql,args)
#获取结果集
return self.cursor.fetchall()
except Exception as e:
print(e)
finally:
self.close()
def get_weather(table_name,city_id):
##################获取天气数据###########
from requests.exceptions import RequestException
import requests
import re
import pandas as pd
from bs4 import BeautifulSoup
import numpy as np
import datetime
########爬取中国气象网原版气温、湿度等信息
def get_one_page(url,headers): # 定义函数，配置网页，请求信息
try:
response=requests.get(url,headers=headers)
if response.status_code==200:
response.encoding='utf-8'
return response.text
return None
except RequestException:
return None
dt = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
print('dt')
dbutil = DBUtil()
sql = 'insert into weather1(Time) values(%s)'
count = dbutil.exeDML(sql%(dt))老师您好，我想把系统当前时间插入到数据库中，在网上查询了相关资料，但是按这样写会报错：
请问应该如何写呢？麻烦您了。
数据库设置如下：
，@param有什么作用？再者就是mapper数据访问接口，这里不需要加@repository注解吗？
京公网安备 11011402011233号