小编jam*_*bcn的帖子

import mysql.connector

connection = mysql.connector.connect(user="REMOVED", 
                                     password="REMOVED", 
                                     host="REMOVED", 
                                     database="REMOVED")

cur = connection.cursor()

# Latitude - remove letter A
cur.execute("UPDATE tau._inm_exportados_test_csv SET latitud = REPLACE (latitud, 'a=','');")
print("Latitude change remove letter A - executed!")

# Longitude - remove letter A
cur.execute("UPDATE tau._inm_exportados_test_csv SET longitud = REPLACE (longitud, 'a=','');")
print("Longitude change remove letter A - executed!")

# Latitude - MODIFY COLUMN
cur.execute("ALTER TABLE tau._inm_exportados_test_csv MODIFY COLUMN latitud DECIMAL(10,6);")
print("Latitude - MODIFY COLUMN - executed!")

# Longitude - MODIFY COLUMN
cur.execute("ALTER TABLE tau._inm_exportados_test_csv MODIFY …

# Import libraries\nimport os, re, subprocess, pyautogui, time, datetime, io\nimport mysql.connector\nimport csv\n\n\nconnection = mysql.connector.connect(\n    user="xxxxx", password="xxxxxx", host="192.168.0.6", database="xxx"\n)\n\ncur = connection.cursor(buffered=True)\n\ntable = "inmuebles"\n\nquery = "SELECT * FROM %s;" % table\n\ncur.execute(query)\n\nwith io.open("test.csv", "w", encoding="utf-8") as f:\n    writer = csv.writer(f, delimiter=";")\n    for row in cur.fetchall():\n        writer.writerow(row)\n\nconnection.commit()\ncur.close()\nconnection.close()\n\n\n##############\n### IMPORT ###\n##############\n\nconnection = mysql.connector.connect(\n    user="xxxxx", password="xxxxx", host="xxxxx", database="xxxx"\n)\n\ncur = connection.cursor(buffered=True)\n\nsql = "SELECT count(*) FROM inmuebles_test"\n\ntry:\n    cur.execute(sql)\n    results = cur.fetchall()\n    for row in results:\n        count = row[0]\n        print("Initially there are %d rows in table" % (count))\n\nexcept:\n    print("Error: unable …