Python работа с базой данных

import vk_api
import config as cnf
import json
import csv
import requests
import re
import MySQLdb
 
params = {
    'owner_id': cnf.owner_id,
    'v': '5.60',
    'filter': 'all',
    'fields': 'cover ',
    'token': cnf.token
}
 
def main():
    # Авторизация
    vk_session = vk_api.VkApi(login=cnf.login, password=cnf.password)
    vk_session.auth()
    vk = vk_session.get_api()
 
    try:
        vk_session.auth(token_only=True)
    except vk_api.AuthError as error_msg:
        print(error_msg)
        return
 
    count = 1
 
    tools = vk_api.VkTools(vk_session)
 
    wall = tools.get_all(
        'wall.get',
        count,
        params
    )
 
    items = wall['items']
    for post in items:
        print(get_data(post))
 
    save_mysql(data)  # сохраняем полученную строку в mysql
 
 
    try:
        save_json(wall)
        print('сохранили в json')
    except:
        print('ошибка сохранения в json')
 
 
def get_data(post):
    '''
    Обрабатываем запрос
    '''
    try:
        post_id = post['id']
    except:
        post_id = 'null'
 
    try:
        post_date = post['date']
    except:
        post_date = 'null'
 
    try:
        post_attachments = get_attachment_data(post)
    except:
        post_attachments = '* * *'
 
    try:
        post_text = post['text']
    except:
        post_text = '* * *'
 
    try:
        post_title = post_text.split('\n\n')[0]
    except:
        post_title = 'Пост №' + post_id
 
    data = {
        'id': post_id,
        'date': post_date,
        'title': post_title,
        'text': post_text,
        'attachments': post_attachments
    }
 
    return data
 
 
def get_attachment_data(post):
 
    if 'attachments' in post:
        list = post['attachments']
 
        photos_list = []
        videos_list = []
        docs_f_list = []
        links_list = []
        pages_list = []
 
        output_attachments_list = [photos_list, videos_list, docs_f_list]
 
        for i in list:
            if i['type'] == 'photo':
                i_photo = i['photo']['photo_604']
                processed_image = ('[img]'+i_photo+'[/img]')
                photos_list.append(processed_image)
 
            elif i['type'] == 'video':
                videos_list.append(get_video_link(i['video']))
 
 
            elif i['type'] == 'doc' and i['doc']['size'] < 10**7:
                docs_f_list.append(i['doc']['url'])
 
            elif i['type'] == 'link':
                links_list.append(i['link']['url'])
 
            elif i['type'] == 'page':
                post.page = i['page']['view_url']
 
    return output_attachments_list
 
 
def get_video_link(video):
    '''
    Return video url from VK video object.
    Args:
    video -- VK video object
    '''
    url = ('{}video.get?owner_id={}&videos={}_{}_{}&count=1&extended=0&v=5.80'
            '&access_token={}').format(
                VK_BASE_URL,
                video['owner_id'],
                video['owner_id'],
                video['id'],
                video['access_key'],
                cnf.token
            )
    video_obj = requests.get(url).json()['response']['items'][0]
    video_url = video_obj['player']
 
    try:
        video_platform = video_obj['platform'].lower()
    except KeyError:
        video_url = 'https://vk.com/video{}_{}'.format(video_obj['owner_id'], video_obj['id'])
        return video_url
 
    if video_platform == 'youtube':
        watch_v = re.search(r'\/([^\/]+)\?', video_url).group(1)
        video_url = 'https://www.youtube.com/watch?v=' + watch_v
 
    elif video_platform == 'vimeo':
        vimeo_video_id = re.search(r'\/([^\/]+)\?', video_url).group(1)
        video_url = 'https://vimeo.com/' + vimeo_video_id
 
    return video_url
 
def get_photo_link(photo_id):
    ACCESS_TOKEN = cnf.token
    params = {
        'v': 5.60,
        'access_token': ACCESS_TOKEN,
        'photos': photo_id
    }
    photo = requests.get(
        'https://api.vk.com/method/video.get',
        params
    )
    return video.json()['response']["items"][0]['player']
 
 
def get_mysql_time_post():
    '''
    Получаем дату последнего поста (для продолжения)
    дату нужно будет конвертировать в Unix time и выдать системе
    только цифры Unix time последнего поста
    '''
    db = MySQLdb.connect(
    #Открыть соединение с базой данных
        cnf.mysql_host,
        cnf.mysql_user,
        cnf.mysql_pass,
        cnf.mysql_base
    )
 
    cursor = db.cursor()
    #Подготовка объекта cursor с помощью метода cursor()
 
    sql = "SELECT * FROM cms_blog_posts \
        WHERE `user_id` = число `blog_id` = число
        взять нужно `pubdate` у самого большого `id`
        КАК?
 
    try:
        cursor.execute(sql)
        #Выполните команду SQL
        results = cursor.fetchall()
        #Получить все строки
 
        for row in sql:
            здесь нужно выбрать у самого большого id
            дату при условии совпадения user_id * blog_id
 
            #Теперь распечатать полученный результат и передаем его в ответе
            print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
                  (fname, lname, age, sex, income )
    except:
        print "Ошибка: не удается получить данные"
 
    # Отключение от сервера
    db.close()
 
    return post_query_time
 
 
def save_photo(photo_id):
    ACCESS_TOKEN = cnf.token
    params = {
        'v': 5.60,
        'access_token': ACCESS_TOKEN,
        'photos': photo_id,
        'photo_sizes': 1
    }
    photo = requests.get(
        'https://api.vk.com/method/photos.getById',
        params
    )
    r = requests.get(
        photo.json()['response'][0]["sizes"][-1]['src'],
    )
 
    with open('img/%s.jpg' % photo.json()['response'][0]["id"], 'wb') as f:
        f.write(r.content)
 
 
def save_doc(doc_id):
    params = {
        'v': API_VERSION,
        'access_token': ACCESS_TOKEN,
        'docs': doc_id
    }
    doc = requests.get(
        'https://api.vk.com/method/docs.getById',
        params
    )
    r = requests.get(
        doc.json()['response'][0]["url"],
    )
    with open('docs/%s.%s' % (doc.json()['response'][0]["title"], doc.json()['response'][0]["ext"]), 'wb') as f:
        f.write(r.content)
 
 
def save_csv(data):
    with open('posts_data.csv', 'a') as cfile:
        writer = csv.writer(cfile, delimiter=",")
        writer.writerow((
            data['id'],
            data['date'],
            data['attachments'],
            data['text']
        ))
 
 
def save_json(data):
    json_file = 'wall.json'
    with open(json_file, 'w') as jfile:
        json.dump(data, jfile, indent=2, ensure_ascii=False)
 
 
def save_mysql():
    '''
    сохраняем пост в mysql
    '''
 
    db = MySQLdb.connect(  #Открыть соединение с базой данных
        cnf.mysql_host,
        cnf.mysql_user,
        cnf.mysql_pass,
        cnf.mysql_base
    )
 
    cursor = db.cursor()
    #Подготовка объекта курсора с помощью метода cursor()
 
    cursor = db.cursor()
    #Подготовка объекта cursor с помощью метода cursor()
 
    sql = """INSERT INTO cms_blog_posts(
                id, user_id, cat_id, blog_id, pubdate, title, feel, music, content,
                content_html, allow_who, edit_times, edit_date, published, seolink,
                comments, comments_count, rating, metadesc, hits, pagetitle,
                meta_keys, meta_desc
            )
            VALUES (
 
                ЗДЕСЬ ПЕРЕМЕННЫЕ?!
                данные получаются для полей:
                    user_id
                    blog_id
                    title
                    content_html
 
                    пока не понятно, как генерировать seolink
        )"""
    try:
        cursor.execute(sql)
        #Выполнить команду SQL
 
        db.commit()
        #Зафиксировать изменения в базе данных
    except:
        db.rollback()
        #Откат в случае ошибки
 
    db.close()
    #Отключение от сервера
 
 
if __name__ == '__main__':
    main()
а

import vk_api
import config as cnf
import time
import MySQLdb
 
 
db = MySQLdb.connect(
#Открыть соединение с базой данных
    cnf.mysql_host,
    cnf.mysql_user,
    cnf.mysql_pass,
    cnf.mysql_base
)
 
cursor = db.cursor()
#Подготовка объекта cursor с помощью метода cursor()
user_id = 2735
blog_id = 239
 
cursor.execute(
    "SELECT max(pubdate) FROM cms_blog_posts WHERE user_id = %s AND blog_id = %s",
        (
            user_id, blog_id
        )
    )
 
try:
    data = cursor.fetchall()
    print(str(data))
except:
    print('Ошибка получения запроса')
 
# Отключение от сервера
db.close()
 
 
date_bd = str(data)
print(int(time.mktime(time.strptime(date_bd, '%Y-%m-%d %H:%M:%S'))))

import vk_api
import config as cnf
import time
import MySQLdb
 
 
db = MySQLdb.connect(
#Открыть соединение с базой данных
    cnf.mysql_host,
    cnf.mysql_user,
    cnf.mysql_pass,
    cnf.mysql_base
)
 
cursor = db.cursor()
#Подготовка объекта cursor с помощью метода cursor()
user_id = 2735
blog_id = 239
 
cursor.execute(
    "SELECT max(pubdate) FROM cms_blog_posts WHERE user_id = %s AND blog_id = %s",
        (
            user_id, blog_id
        )
    )
 
try:
    data = cursor.fetchone()
except:
    print('Ошибка получения запроса')
 
# Отключение от сервера
db.close()
 
print(int(time.mktime(time.strptime(str(data[0]), '%Y-%m-%d %H:%M:%S'))))