編集履歴

質問編集履歴

削除された内容の復元を行いました

2018/06/15 01:45

投稿

beginner_py

スコア13

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -1,1 +1,100 @@
+お見苦しいソースですが、salesforceとmysqlのデータ連携を図っておりまして、
+salesfoceへの接続　s2hdb.py
+アップデーター　　s2h_updater.py
+下記プログラム　　samlple.com
+mysqlの最新更新日とsalesforceの最終更新日を比較しsalesforce側の日付が新しければmysql側をupsertするというプログラムです。
+実行すると
+File "/home/dbcon/sample.py", line 96, in lo_update_companies
+   cur.execute(q)
+UnboundLocalError: local variable 'q' referenced before assignment
-一旦削除いたします。
+とエラーが出てしまします。
+色々試したのですが解決できず。。。。
+解決方法を教えていただきたいです。
+```python2.7
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import s2hdb
+from datetime import datetime as dt
+from operator import add
+#
+# Salesforce handle Functions
+#
+def sf_get_last_modified_date():
+   sf = s2hdb.sf_get_descriptor()
+   q = "SELECT LastModifiedDate FROM Account " + \
+                   "ORDER BY LastModifiedDate DESC LIMIT 1"
+   r = sf.query_all(q)
+   last_modified = dt.strptime(r["records"][0]["LastModifiedDate"],
+                                   '%Y-%m-%dT%H:%M:%S.000+0000')
+   return last_modified
+def sf_get_updated_companies(last_modified):
+   sf = s2hdb.sf_get_descriptor()
+   q = "SELECT Name, Website, Description, Description_JP__c, " + \
+       "Core_Technology__c, Core_Technology_JP__c, Development_Status__c, " + \
+       "Development_Status_JP__c, Application__c, Application_JP__c, Tags__c" + \
+       " FROM Account WHERE LastModifiedDate > " + \
+       last_modified.strftime('%Y-%m-%dT%H:%M:%S.000+0000')
+   results = sf.query_all(q)
+   coms = []
+   for r in results["records"]:
+       com = []
+       elements = ['Name', 'Website', 'Description', 'Description_JP__c',
+                   'Core_Technology__c', 'Core_Technology_JP__c', 'Development_Status__c',
+                    'Development_Status_JP__c', 'Application__c', 'Application_JP__c', 'Tags__c']
+       elements = [str(e) for e in elements]
+       for e in elements:
+           # Convert NoneType Object as ""
+           if (r[e] is None):
+               r[e] = str("")
+           r[e] = r[e].encode('utf-8')
+           r[e] = r[e].replace('\'', '\'\'')
+　         if (e == 'Tags__c'):
+               if (r[e] is None):
+                   r[e] = str("")
+               com.append('{0}'.format(r[e]).strip().split(";"))
+           else:
+               com.append('\'{0}\''.format(r[e]))
+       # Duplication check.
+       # It seems salesforce returns duplicated records.
+       duplicated = False
+       for c in coms:
+           if coms[0] == '\'{0}\''.format(r["Name"]):
+                  duplicated = True
+       if (duplicated is True):
+           continue
+       coms.append(com)
+   return coms
+#
+# Local DB handle functions
+#
+def lo_get_last_modified_date():
+   con = s2hdb.lo_get_descriptor()
+   cur = con.cursor()
+   q = "SELECT last_modified from company ORDER BY last_modified DESC LIMIT 1"
+   cur.execute(q)
+   if (cur.rowcount == 0):
+       # We want to move all from salesforce, so just set very early date
+       last_modified = dt.strptime("2000/1/1 00:00:00", '%Y/%m/%d %H:%M:%S')
+   else:
+       last_modified = cur.fetchone()[0]
+   cur.close()
+   return last_modified
+def lo_update_companies(data):
+   if (len(data) == 0):
+       return
+   con = s2hdb.lo_get_descriptor()
+   cur = con.cursor()
+   coms = []
+   for t in data:
+       coms.append(t[0:10])
+   q = "INSERT INTO company(legal_name, website, desc, desc_jp, " + \
+       "core_tech, core_tech_jp, " + \
+       "development_status, development_status_jp, application, application_jp, cat_name) " + \
+       "VALUES " + \
+       ", ".join(map(lambda x: "(" + ",".join(x) + ")", coms)) + " " + \
+       "ON DUPLICATE KEY UPDATE legal_name = VALUES (legal_name)" + \
+   cur.execute(q)
+   cur.close()
+   con.commit()
+コード
+```

一旦削除

2018/06/15 01:45

投稿

退会済みユーザー

スコア0

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -1,118 +1,1 @@
-お見苦しいソースですが、salesforceとmysqlのデータ連携を図っておりまして、
-salesfoceへの接続　s2hdb.py
-アップデーター　　s2h_updater.py
-下記プログラム　　samlple.com
-mysqlの最新更新日とsalesforceの最終更新日を比較しsalesforce側の日付が新しければmysql側をupsertするというプログラムです。
-実行すると
- File "/home/dbcon/sample.py", line 96, in lo_update_companies
-    cur.execute(q)
-UnboundLocalError: local variable 'q' referenced before assignment
-とエラーが出てしまします。
+一旦削除いたします。
-色々試したのですが解決できず。。。。
-解決方法を教えていただきたいです。
-```python2.7
-#!/usr/bin/env python
-# -*- coding: utf-8 -*-
-import s2hdb
-from datetime import datetime as dt
-from operator import add
-#
-# Salesforce handle Functions
-#
-def sf_get_last_modified_date():
-    sf = s2hdb.sf_get_descriptor()
-    q = "SELECT LastModifiedDate FROM Account " + \
-                    "ORDER BY LastModifiedDate DESC LIMIT 1"
-    r = sf.query_all(q)
-    last_modified = dt.strptime(r["records"][0]["LastModifiedDate"],
-                                    '%Y-%m-%dT%H:%M:%S.000+0000')
-    return last_modified
-def sf_get_updated_companies(last_modified):
-    sf = s2hdb.sf_get_descriptor()
-    q = "SELECT Name, Website, Description, Description_JP__c, " + \
-        "Core_Technology__c, Core_Technology_JP__c, Development_Status__c, " + \
-        "Development_Status_JP__c, Application__c, Application_JP__c, Tags__c" + \
-        " FROM Account WHERE LastModifiedDate > " + \
-        last_modified.strftime('%Y-%m-%dT%H:%M:%S.000+0000')
-    results = sf.query_all(q)
-    coms = []
-    for r in results["records"]:
-        com = []
-        elements = ['Name', 'Website', 'Description', 'Description_JP__c',
-                    'Core_Technology__c', 'Core_Technology_JP__c', 'Development_Status__c',
-                     'Development_Status_JP__c', 'Application__c', 'Application_JP__c', 'Tags__c']
-        elements = [str(e) for e in elements]
-        for e in elements:
-            # Convert NoneType Object as ""
-            if (r[e] is None):
-                r[e] = str("")
-            r[e] = r[e].encode('utf-8')
-            r[e] = r[e].replace('\'', '\'\'')
-　          if (e == 'Tags__c'):
-                if (r[e] is None):
-                    r[e] = str("")
-                com.append('{0}'.format(r[e]).strip().split(";"))
-            else:
-                com.append('\'{0}\''.format(r[e]))
-        # Duplication check.
-        # It seems salesforce returns duplicated records.
-        duplicated = False
-        for c in coms:
-            if coms[0] == '\'{0}\''.format(r["Name"]):
-                   duplicated = True
-        if (duplicated is True):
-            continue
-        coms.append(com)
-    return coms
-#
-# Local DB handle functions
-#
-def lo_get_last_modified_date():
-    con = s2hdb.lo_get_descriptor()
-    cur = con.cursor()
-    q = "SELECT last_modified from company ORDER BY last_modified DESC LIMIT 1"
-    cur.execute(q)
-    if (cur.rowcount == 0):
-        # We want to move all from salesforce, so just set very early date
-        last_modified = dt.strptime("2000/1/1 00:00:00", '%Y/%m/%d %H:%M:%S')
-    else:
-        last_modified = cur.fetchone()[0]
-    cur.close()
-    return last_modified
-def lo_update_companies(data):
-    if (len(data) == 0):
-        return
-    con = s2hdb.lo_get_descriptor()
-    cur = con.cursor()
-    coms = []
-    for t in data:
-        coms.append(t[0:10])
-    q = "INSERT INTO company(legal_name, website, desc, desc_jp, " + \
-        "core_tech, core_tech_jp, " + \
-        "development_status, development_status_jp, application, application_jp, cat_name) " + \
-        "VALUES " + \
-        ", ".join(map(lambda x: "(" + ",".join(x) + ")", coms)) + " " + \
-        "ON DUPLICATE KEY UPDATE legal_name = VALUES (legal_name)" + \
-    cur.execute(q)
-    cur.close()
-    con.commit()
-コード
-```