postgresql.py 文件源码

def perform_group_create(self, intent):
        payload = '{"admins": [], "users": []}'
        async with self.connection.acquire() as conn:
            async with conn.cursor() as cur:
                try:
                    await cur.execute("INSERT INTO groups VALUES (%s, %s);",
                        (intent.name, payload))
                except IntegrityError:
                    raise GroupAlreadyExist('Group already exist.')