ファイルの保存先パスをDBに格納

プログラム内「-------」「--------」の部分のアドバイスをお願いしたいです。
「-------」「--------」ではすでにMysqlに格納されている企業ID(com_id）とSalesforceでファイルを保持していた企業ID(Id)を比較して同じ企業であればMysqlにファイルの保存先パスを格納するというものを作ろうとしています。
またファイル形式ごとにパスの格納先が異なり
画像であれば（picture）
その他は(attachment)
に格納したいのです。

正直どうかいていいかわからず。。。。
どなたか教えていただきたいです。

python
1import urllib3.request
2import mysql.connector
3from urllib.parse import urlparse
4
5sfdc = sf.Salesforce()
6sfdc.authenticate(client_id=client_id,client_secret=client_secret,username=username,password=password)
7
8
9接続情報のため省略
10
11
12
13#get id, filename from contentversion
14version = {}
15query_results = sfdc.query("SELECT Id, ContentDocumentId, Title, FileExtension FROM ContentVersion")
16for record in query_results["records"]:
17  if record["ContentDocumentId"] not in version:
18    version[record["ContentDocumentId"]] = []
19  version[record["ContentDocumentId"]].append({"Id":record["Id"],"Filename":record["Title"] + "." + record["FileExtension"]})
20
21#download)
22query_results = None
23query_results = sfdc.query("SELECT Id, ContentDocumentId, LinkedEntityId FROM ContentDocumentLink where LinkedEntityId in (SELECT Id FROM " + api_object + ")")
24for record in query_results["records"]:
25  print(record)
26  if limit_download <= 0:
27    break
28  if record["ContentDocumentId"] in version:
29    vlist = version[record["ContentDocumentId"]]
30    for v in vlist:
31      print("  downloading:" + v["Id"] + "  " + v["Filename"])
32      urlpath = "/sobjects/ContentVersion/" + v["Id"] + "/VersionData"
33      filepath = base_folder + api_object + "/" + record["LinkedEntityId"] + "/" + v["Filename"]
34      fname = v["Filename"]
35      print(fname)
36      resp = sfdc.get(urlpath)
37      limit_download -= 1
38      if not os.path.exists(os.path.dirname(filepath)):
39        os.makedirs(os.path.dirname(filepath))
40
41      with open(filepath, "wb") as f:
42        print(filepath)
43        f.write(resp.content)
44
45
46----------------------------------------------------------------------------------------
47      __cur = con.cursor()
48      q = "SELECT com_id from company  Where com_id   *******"
49      cur.execute(q)
50      if(fname == "*doc" or fname == "*docs" or fname == "*txt"):
51          print("対象外です")
52　　　　　 continue
53      elif(fname == "*jpg" or fname == "*png" or fname == "*gif"):
54      　   q = "INSERT INTO company (picture) VALUES filepath " + \
55           "ON DUPLICATE KEY UPDATE com_id = VALUES(com_id)"
56           cur.execute(q)
57           print("画像です")
58      else:
59      q = "INSERT INTO company (attachment) VALUES filepath " + \
60        "ON DUPLICATE KEY UPDATE com_id = VALUES(com_id)"
61       cur.execute(q)
62       con.comit()**__
63---------------------------------------------------------------------------------------
64