admin/GoogleScrape
1
0
Fork 0
mirror of https://github.com/timberjoegithub/GoogleScrape.git synced 2026-07-22 00:19:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

update database

Browse Source
This commit is contained in:
Joe Steele
2024-06-06 17:33:51 -04:00
parent 484ce73ac2
commit fe703c9c65
1 changed files with 20 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
social.py
+19
View File
@@ -103,6 +103,7 @@ class Posts(Base):
businessurl = sqlalchemy.Column(sqlalchemy.String(length=128, collation="utf8"))
longitude = sqlalchemy.Column(sqlalchemy.Float())
latitude = sqlalchemy.Column(sqlalchemy.Float())
google = sqlalchemy.Column(sqlalchemy.Boolean, default=False)
#active = sqlalchemy.Column(sqlalchemy.Boolean, default=True)
##################################################################################################
@@ -1339,6 +1340,24 @@ def process_reviews(outputs):
try:
print(' write to xls for web')
outputs['datawb'].save(env.xls)
except Exception as error:
print(" An error occurred writing Excel file:", type(error).__name__) # An error occurred: try:
try:
print(' write to DB for web')
# outputs['postssession'].update save(env.xls)
stmt = (sqlalchemy.update('posts').where("posts".c.name == processrow[1].value).values(google=True))
print(stmt)
# outputs['postssession'].query(
# processrow[1].value
# ).filter(
# processrow[1].value
# ).update({
# processrow[1].value.dicPostComplete: '{'google': 1, 'web': 0, 'yelp': 0, 'facebook': 0, 'xtwitter': 0, 'instagram': 0, 'tiktok': 0}',})
# # UserModel.email: 'johndeo@domain.com',
# # UserModel.city: 'New York'
# #})
# outputs['postssession'].commit()
stmt.commit()
except Exception as error:
print(" An error occurred writing Excel file:", type(error).__name__) # An error occurred:
except Exception as error: