try:
with db_config.session_resource() as session:
sql = text("""
INSERT INTO test1 (check_id) VALUES (:v1)"
""")
session.execute(sql, {"v1": 's"s'})
except Exception as e:
print(e)
s = str(e)
# s = s.replace("'", "")
# s = s.replace('"', "")
print(s)
# s = re.sub(r'["\']', '', s)
print(234, s)
with db_config.session_resource() as session:
sql = text("""
INSERT INTO test1 (check_id, d) VALUES ('abc',:v1)
""")
session.execute(sql, {"v1": json.dumps({"a": s})})
# sql = f"""
# INSERT INTO test1 (check_id, d) VALUES ('a','{json.dumps({"a": s})}')
# """
# cursor.execute(sql)
print(2342)
with db_config.session_resource() as session:
sql = text(f"""
insert into cmap_qc_log
(check_id,task_id,mesh_id,rule_id,rule_version,rule_logic,log_level,log_msg,modify_msg,
check_layer,check_field,check_field_val,check_val,id_col_name,id_col_val,create_time,
log_type,geom)
values(:check_id,:task_id,:mesh_id,:rule_id,:rule_version,:rule_logic,:log_level,:log_msg,
:modify_msg, :check_layer,:check_field,:check_field_val,:check_val,:id_col_name,:id_col_val,
:create_time,:log_type,st_geomfromtext(:geom,4326))
RETURNING id
""")
result = session.execute(sql, log.model_dump())
return result.fetchone()[0]
with db_util.get_cursor(check_db_cfg) as cursor:
try:
sql = """
INSERT INTO test1 (check_id) VALUES (%s)"
"""
cursor.execute(sql, ('s"s',))
except Exception as e:
print(e)
s = str(e)
# s = s.replace("'", "")
# s = s.replace('"', "")
print(s)
# s = re.sub(r'["\']', '', s)
print(234, s)
with db_util.get_cursor(check_db_cfg) as cursor:
sql = """
INSERT INTO test1 (check_id, d) VALUES (%s,%s)
"""
cursor.execute(sql, ("a", json.dumps({"a": s}),))
# sql = f"""
# INSERT INTO test1 (check_id, d) VALUES ('a','{json.dumps({"a": s})}')
# """
# cursor.execute(sql)
print(2342)
in
with db_util.get_cursor(wdb) as cursor:
sql = """
select id,st_astext(geometry) as geometry
from public."HAD_RDBOUND_LINK" WHERE id in %s;
"""
ids = ('227791813806083333', '290095456722557441')
cursor.execute(sql, (ids,))
rows = cursor.fetchall()
for row in rows:
print(row)
sql = """
select id,st_astext(geometry) as geometry
from public."HAD_RDBOUND_LINK" WHERE id in %s
"""
ids = ['227791813806083333', '290095456722557441']
cursor.execute(sql, (tuple(ids),))
rows = cursor.fetchall()
for row in rows:
print(row)
网友评论