def upsert_prelude_clip(self,project_ref=None,asset_name=None,asset_relink_skipped=None,asset_type=None,
uuid=None,created_date=None,drop_frame=None,duration=None,file_path=None,frame_rate=None,
import_date=None,parent_uuid=None,start_time=None):
cursor=self.conn.cursor()
self.conn.commit()
try:
sqlcmd="""insert into prelude_clips (asset_name,asset_relink_skipped,asset_type,class_id,created_date,drop_frame,
duration_text,file_path,frame_rate,import_date,project,start_time,parent_id)
values
(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s) returning id
"""
cursor.execute(sqlcmd, (asset_name,asset_relink_skipped,asset_type,uuid,created_date,drop_frame,duration,file_path,
frame_rate,import_date,parent_uuid,start_time,project_ref))
except psycopg2.IntegrityError as e:
#if e.startswith('duplicate key'):
self.conn.rollback()
sqlcmd = """update prelude_clips set
asset_name=%s,
asset_relink_skipped=%s,
asset_type=%s,
created_date=%s,
drop_frame=%s,
duration_text=%s,
frame_rate=%s,
import_date=%s,
project=%s,
start_time=%s,
parent_id=%s
where class_id=%s and file_path=%s returning id"""
cursor.execute(sqlcmd,(asset_name,asset_relink_skipped,asset_type,created_date,drop_frame,duration,
frame_rate,import_date,parent_uuid,start_time,project_ref,uuid,file_path))
self.conn.commit()
result=cursor.fetchone()
return result[0]
评论列表
文章目录