Python 은 my sql 데이터베이스 업데이트 표 데이터 인터페이스 기능 을 실현 합 니 다.
8534 단어 pythonmysql표 데이터 인터페이스
어제 프로젝트 수요 에 따라 표 의 업데이트 인 터 페 이 스 를 추가 하여 예측 모델 훈련 데 이 터 를 저장 해 야 하기 때문에 스스로 코드 를 써 서 이 기능 을 실현 했다.시작 하기 전에 python 작업 my sql 데이터 베 이 스 를 공유 했다.
#coding=utf-8
import MySQLdb
conn= MySQLdb.connect(
host='localhost',
port = 3306,
user='root',
passwd='123456',
db ='test',
)
cur = conn.cursor()
#
#cur.execute("create table student(id int ,name varchar(20),class varchar(30),age varchar(10))")
#
#cur.execute("insert into student values('2','Tom','3 year 2 class','9')")
#
#cur.execute("update student set class='3 year 1 class' where name = 'Tom'")
#
#cur.execute("delete from student where age='9'")
cur.close()
conn.commit()
conn.close()
>>> conn = MySQLdb.connect(host='localhost',port = 3306,user='root', passwd='123456',db ='test',)
Connect()방법 은 데이터베이스 연결 을 만 드 는 데 사 용 됩 니 다.사용자 이름,비밀번호,호스트 등 인 자 를 지정 할 수 있 습 니 다.이것 은 데이터베이스 에 연 결 된 것 일 뿐 데이터 베 이 스 를 조작 하려 면 커서 를 만들어 야 합 니 다.
>>> cur = conn.cursor()
가 져 온 데이터베이스 연결 conn 의 cursor()방법 으로 커서 를 만 듭 니 다.>>> cur.execute("create table student(id int ,name varchar(20),class varchar(30),age varchar(10))")
커서 cur 작업 execute()방법 을 통 해 순수한 sql 문 구 를 쓸 수 있 습 니 다.execute()방법 에 sql 문 구 를 써 서 데 이 터 를 조작 합 니 다.>>>cur.close()
cur.close()커서 닫 기>>>conn.commit()
conn.comit()방법 은 사물 을 제출 할 때 데이터베이스 에 데 이 터 를 삽입 할 때 반드시 이 방법 이 있어 야 합 니 다.그렇지 않 으 면 데이터 가 진정 으로 삽입 되 지 않 습 니 다.>>>conn.close()
Conn.close()데이터베이스 연결 닫 기다음은 본문의 본문 을 시작 합 니 다.
Python my sql 업데이트 표 데이터 인터페이스 구현
예제 코드
# -*- coding: utf-8 -*-
import pymysql
import settings
class mysql(object):
def __init__(self):
self.db = None
def connect(self):
self.db = pymysql.connect(host=settings.ip, port=settings.port, user=settings.mysql_user, passwd=settings.mysql_passwd, db=settings.database, )
# print("connect is ok")
# return 1
def disconnect(self):
self.db.close()
# return -1
def create_table(self, tablename, columns, spec='time'):
"""
:param tablename:
:param spec:
:param columns: []
:return:
"""
type_data = ['int', 'double(10,3)']
cursor = self.db.cursor()
sql="create table %s("%(tablename,)
sqls=[]
for col in columns:
# time_num
if col==spec:
sqls.append('%s %s primary key'%(col,type_data[0]))
else:
sqls.append('%s %s'%(col,type_data[1]))
sqlStr = ','.join(sqls)
sql+=sqlStr+')'
try:
cursor.execute(sql)
print("Table %s is created"%tablename)
except:
self.db.rollback()
def is_table_exist(self, tablename,dbname):
cursor=self.db.cursor()
sql="select table_name from information_schema.TABLES where table_schema='%s' and table_name = '%s'"%(dbname,tablename)
#results="error:Thie table is not exit"
try:
cursor.execute(sql)
results = cursor.fetchall() #
except:
#
raise Exception('This table does not exist')
if not results:
return None
else :
return results
# print datas
def insert_mysql_with_json(self, tablename, datas):
"""
:param tablename:
:param datas: {(key: value),.....}
:return:
"""
# keys = datas[0]
keys = datas[0].keys()
keys = str(tuple(keys))
keys = ''.join(keys.split("'")) # '
print(keys)
ret = []
for dt in datas:
values = dt.values() ## ‘str' object has no attribute#
sql = "insert into %s" % tablename + keys
sql = sql + " values" + str(tuple(values))
ret.append(sql)
# print("1")
# print keys insert into %tablename dat[i] values str[i]
self.insert_into_sql(ret)
print("1")
def insert_into_sql(self,sqls):
cursor = self.db.cursor()
for sql in sqls:
# sql
try:
cursor.execute(sql)
self.db.commit()
# print("insert %s" % sql, "success.")
except:
# Rollback in case there is any error
self.db.rollback()
#
def find_columns(self, tablename):
sql = "select COLUMN_NAME from information_schema.columns where table_name='%s'" % tablename
cursor = self.db.cursor()
try:
cursor.execute(sql)
results = cursor.fetchall()
except:
raise Exception('hello')
return tuple(map(lambda x: x[0], results))
def find(self, tablename, start_time, end_time, fieldName=None):
"""
:param tablename: test_scale1015
:param fieldName: None or (columns1010, columns1011, columns1012, columns1013, time)
:return:
"""
cursor = self.db.cursor()
sql = ''
if fieldName==None:
fieldName = self.find_columns(tablename)
sql = "select * from %s where time between %s and %s" % (tablename, str(start_time), str(end_time))
# print('None')
else:
fieldNameStr = ','.join(fieldName)
sql = "select %s from %s where time between %s and %s" % (
fieldNameStr, tablename, str(start_time), str(end_time))
# print('sm')
try:
cursor.execute(sql)
results = cursor.fetchall()
except:
raise Exception('hello')
return fieldName, results,
# data = [{'time':123321,'predict':1.222},{'time':123322,'predict':1.223},{'time':123324,'predict':1.213}]
def updata(self,datas, tablename):
cursor = self.db.cursor()
columns = []
for data in datas:
for i in data.keys():
columns.append(i)
# print(columns)
break
# columns_2=columns[:]
db.connect()
if db.is_table_exist(settings.tablename_2, settings.database):
# exists
# pass
for col in columns:
if col != 'time':
sql = "alter table %s add column %s double(10,3);" % (settings.tablename_2, col)
try:
cursor.execute(sql)
print("%s is altered ok" % (col))
except:
print("alter is failed")
ret = []
for i in datas:
col = []
for ii in i.keys():
col.append(ii)
#time = col[0] and predict = col[1]
time_data = i[col[0]]
predic_data = i[col[1]]
sql = "update %s set %s='%s'where %s=%s"%(settings.tablename_2,col[1],predic_data,col[0],time_data)
ret.append(sql)
self.insert_into_sql(ret)
# db.insert_mysql_with_json(tablename, datas)
else:
# no exists
db.create_table(settings.tablename_2, columns)
db.insert_mysql_with_json(settings.tablename_2, datas)
db = mysql()
그 중 update()함 수 는 새로 추 가 된 인터페이스 입 니 다.들 어 오 는 data 의 사례
data = [{'time':123321,'predict':1.222},{'time':123322,'predict':1.223},{'time':123324,'predict':1.213}]
는 이 렇 습 니 다.하나의 목록 에는 여러 개의 사전 이 있 고,사전 마다 time 과 predict 가 있 습 니 다.predict 저장 이 필요 하 다 면2,predict_3 시 에는 업데이트 작업 을 수행 합 니 다.그렇지 않 으 면 창 표 와 데 이 터 를 삽입 하 는 작업 만 수행 합 니 다~~~~~~
쉬 워 보 이 죠~~~~~
이 인 터 페 이 스 는 아직 최적화 등 작업 을 하지 않 아 지루 합 니 다~~~
프로젝트 는 아직 테스트 단계 이기 때문에 먼저 달 릴 때 까지 최 적 화 를 고려 하고 있 습 니 다~~~~~~
총결산
이상 은 이 글 의 전체 내용 입 니 다.본 논문 의 내용 이 여러분 의 학습 이나 업무 에 어느 정도 참고 학습 가치 가 있 기 를 바 랍 니 다.궁금 한 점 이 있 으 시 면 댓 글 을 남 겨 주 셔 서 저희 에 대한 지지 에 감 사 드 립 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
로마 숫자를 정수로 또는 그 반대로 변환그 중 하나는 로마 숫자를 정수로 변환하는 함수를 만드는 것이었고 두 번째는 그 반대를 수행하는 함수를 만드는 것이었습니다. 문자만 포함합니다'I', 'V', 'X', 'L', 'C', 'D', 'M' ; 문자열이 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.