VideoToArticles/deal/db_deal.py

"""
@author: luojunhui
"""


async def insert_text_mysql(mysql_client, video_id, text, title):
    """
    :return:
    """
    select_sql = f"""select video_id from video_text where video_id = {video_id};"""
    result = await mysql_client.select(select_sql)
    print(result)
    if result:
        return {"duplicated": "vid already exists", "vid": video_id}
    else:
        insert_sql = f"""
        insert into video_text
        (video_id, video_text, title)
        values 
        ({video_id},'{text}', '{title}');
        """
        await mysql_client.async_insert(insert_sql)
        return {"info": "success insert text into mysql", "vid": video_id}


async def get_text_by_id(mysql_client, video_id):
    """
    获取视频id
    :param mysql_client:
    :param video_id:
    :return:
    """
    select_sql = f"""select video_text from video_text where video_id = {video_id}"""
    result = await mysql_client.select(select_sql)
    if result:
        return result[0][0]
    else:
        return None