初始版本ck数据增改查
This commit is contained in:
parent
6231e93531
commit
9e245b284b
@ -40,10 +40,11 @@ class InterviewDo:
|
|||||||
insert_data = [self.data_in]
|
insert_data = [self.data_in]
|
||||||
if isinstance(self.data_in, list):
|
if isinstance(self.data_in, list):
|
||||||
insert_data = self.data_in
|
insert_data = self.data_in
|
||||||
|
keys = ()
|
||||||
# sql = f"insert into test.interview(auth, state, name, phone, position, teacher_name, boss_name, stage, " \
|
for data in insert_data:
|
||||||
# f"interview_type,interview_location, interview_time) values"
|
keys = tuple(data.keys())
|
||||||
sql = f"insert into HR.resumes(name, kardid) values"
|
break
|
||||||
|
sql = f"insert into HR.resumes{keys} values"
|
||||||
print(sql)
|
print(sql)
|
||||||
return {'sql': sql,
|
return {'sql': sql,
|
||||||
'insert_data': insert_data
|
'insert_data': insert_data
|
||||||
@ -53,19 +54,37 @@ class InterviewDo:
|
|||||||
updateStr = ''
|
updateStr = ''
|
||||||
whereStr = ''
|
whereStr = ''
|
||||||
for key, value in self.data_in.items():
|
for key, value in self.data_in.items():
|
||||||
updateStr += str(key) + ' = ' + str(value) + ' '
|
if isinstance(value, str):
|
||||||
|
updateStr += str(key) + ' = ' + "'" + value + "'" + ' '
|
||||||
|
continue
|
||||||
|
updateStr += str(key) + ' = ' + value + ' '
|
||||||
for key, value in self.where.items():
|
for key, value in self.where.items():
|
||||||
whereStr += str(key) + ' = ' + str(value) + ' '
|
if isinstance(value, str):
|
||||||
updateStr = updateStr.strip()
|
whereStr += str(key) + ' = ' + "'" + value + "'" + ' '
|
||||||
whereStr = whereStr.strip()
|
continue
|
||||||
sql = f"alter table HR.resumes update `{updateStr}` where `{whereStr}`"
|
whereStr += str(key) + ' = ' + value + ' '
|
||||||
|
updateStr.strip()
|
||||||
|
whereStr.strip()
|
||||||
|
sql = f"alter table HR.resumes update {updateStr} where {whereStr}"
|
||||||
|
|
||||||
print(sql)
|
print(sql)
|
||||||
return {'sql': sql,
|
return {'sql': sql,
|
||||||
}
|
}
|
||||||
|
|
||||||
def find_interview_sql(self):
|
def find_interview_sql(self):
|
||||||
sql = f"select `{self.find_column}` from HR.resumes where {self.where}"
|
whereStr = ''
|
||||||
|
findStr = ''
|
||||||
|
for fstr in self.find_column:
|
||||||
|
findStr += fstr + ', '
|
||||||
|
for key, value in self.where.items():
|
||||||
|
if isinstance(value, str):
|
||||||
|
whereStr += str(key) + ' = ' + "'" + value + "'" + ' '
|
||||||
|
continue
|
||||||
|
whereStr += str(key) + ' = ' + value + ' '
|
||||||
|
whereStr = whereStr.strip()
|
||||||
|
findStr = findStr.strip().strip(',')
|
||||||
|
# sql = f"select {findStr} from HR.resumes where {whereStr}"
|
||||||
|
sql = f"select * from HR.resumes where {whereStr}"
|
||||||
print(sql)
|
print(sql)
|
||||||
return {'sql': sql,
|
return {'sql': sql,
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user