Added some basic logic to import OPML files into database. Broke some sql server settings into separate file.
This commit is contained in:
9
database.py
Normal file
9
database.py
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
import sqlalchemy as sql
|
||||||
|
|
||||||
|
db_URI = 'mysql+pymysql://pc:pc@192.168.86.198/Podcast'
|
||||||
|
# db_URI = 'mysql+pymysql://pc:pc@dandembinski.duckdns.org:80/Podcast'
|
||||||
|
|
||||||
|
engine = sql.create_engine(db_URI)
|
||||||
|
con = engine.connect()
|
||||||
|
|
||||||
|
metadata = sql.MetaData()
|
||||||
49
main.py
49
main.py
@@ -1,14 +1,51 @@
|
|||||||
import opml
|
import opml
|
||||||
|
# import sqlalchemy as db
|
||||||
|
import database.py as db
|
||||||
|
|
||||||
|
|
||||||
|
def podcastImport (userID):
|
||||||
|
|
||||||
|
|
||||||
|
podcasts = db.Table('Users', db.metadata, autoload=True, autoload_with=db.engine)
|
||||||
|
|
||||||
def podcastImport ():
|
|
||||||
outline = opml.parse("podcast_republic_podcasts.opml")
|
outline = opml.parse("podcast_republic_podcasts.opml")
|
||||||
x = len(outline)
|
x = len(outline)
|
||||||
y=0
|
y=0
|
||||||
|
|
||||||
while y < x:
|
while y < x:
|
||||||
print(outline[y].title)
|
title = outline[y].title
|
||||||
print(outline[y].xmlUrl)
|
url = outline[y].xmlUrl
|
||||||
print(outline[y].pr_artwork)
|
artwork = outline[y].py_artwork
|
||||||
print(outline[y].pr_desc)
|
desc = outline[y].pr_desc
|
||||||
print()
|
query = """insert into """ + podcasts+""""(userID, title, URL, desc, artworkURL values (""" + userID + """,""" + title + """,""" + url + """,""" + desc + """,""" + artwork + """)"""
|
||||||
|
db.con.execute(query)
|
||||||
y=y+1
|
y=y+1
|
||||||
|
|
||||||
|
|
||||||
|
def login():
|
||||||
|
username = 'dan'
|
||||||
|
password = 'password'
|
||||||
|
|
||||||
|
|
||||||
|
user = db.Table('Users', db.metadata, autoload=True, autoload_with=db.engine)
|
||||||
|
|
||||||
|
query = db.text(""" select userID from """ + user + """ where username =""" + username)
|
||||||
|
result = db.con.execute(query).fetchone()
|
||||||
|
|
||||||
|
db.con.close()
|
||||||
|
|
||||||
|
return result
|
||||||
|
|
||||||
|
|
||||||
|
while True:
|
||||||
|
userID = None
|
||||||
|
|
||||||
|
print("1. Login \n 2. Upload")
|
||||||
|
val = input(">>>")
|
||||||
|
if val == "1":
|
||||||
|
userID = login()
|
||||||
|
elif val == "2":
|
||||||
|
if userID is None or userID == '':
|
||||||
|
print("Please login first")
|
||||||
|
else:
|
||||||
|
podcastImport(userID)
|
||||||
|
|||||||
Reference in New Issue
Block a user