Crear cuenta
$ sudo pip install dbfread
from dbfread import DBF
for record in DBF('people.dbf'):
print(record)
from dbfread import DBF
def sql_create_table(db):
""" Para crear la tabla con sql.
(Ajustar hasta que funcione correctamente) """
columnas = []
campos = db.fields
for campo in campos:tipo = campo.type
if tipo == "C": # Caracter.
tmp = "%s VARCHAR(%s)" % (campo.name, campo.length + 1)
columnas.append(tmp)
elif tipo == "N": # Numerico.
tmp = "%s NUMERIC(%s, %s)" % (campo.name, campo.length, campo.decimal_count)
columnas.append(tmp)
elif tipo == "D": # Fecha.
tmp = "%s DATE" % (campo.name,)
columnas.append(tmp)
else:raise NotImplementedError("Tipo %s no implementado" % tipo)
q = "CREATE TABLE IF NOT EXISTS %(nombre)s\n(\n%(columnas)s\n);"
q = q % dict(nombre=db.name.rstrip(".dbf"),
columnas=",\n".join(columnas))
return q
# Conexion con el dbf.
db = DBF("tabla.dbf")
# Estructura de la tabla.
sql = sql_create_table(db)
# Establecer una conexion a mysql y ejecutar este script.
print(sql)
# # Datos.
# for record in db:
# print(record)
try:import pymysql
except ImportError:pass
from dbfread import DBF
DB_HOST = 'localhost'
DB_USER = 'root'
DB_PASS = 'xxxxxx'
DB_NAME = 'repositorio'
def run_query(query=''):
datos = [DB_HOST, DB_USER, DB_PASS, DB_NAME]
conn = pymysql.connect(*datos)
cursor = conn.cursor()
cursor.execute(query)
if query.upper().startswith('SELECT'):
data = cursor.fetchall()
else:conn.commit()
data = Nonecursor.close()
conn.close()
return data
def sql_create_table(db):
columnas = []
campos = db.fields
columnas.append("id INT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY")
for campo in campos:tipo = campo.type
if tipo == "C":
tmp = "%s VARCHAR(%s)" % (campo.name, campo.length + 1)
columnas.append(tmp)
elif tipo == "N":
tmp = "%s NUMERIC(%s, %s)" % (campo.name, campo.length, campo.decimal_count)
columnas.append(tmp)
elif tipo == "D":
tmp = "%s DATE" % (campo.name)
columnas.append(tmp)
else:raise NotImplementedError('Tipo %s no implementado' % tipo)
q = "CREATE TABLE IF NOT EXISTS %(nombre)s\n(\n%(columnas)s\n);"
q = q % dict(nombre=db.name.rstrip(".dbf"), columnas=",\n".join(columnas))
return q
#Conexion con el dbf.
db = DBF('r:/prj/fox/sueldos/destino.dbf')
#Estructura de la tabla
sql = sql_create_table(db)
#Establecer una conexion a mysql y ejecutar el script
#print(sql)
run_query(sql)
def sql_insert_into(dbf):
""" OBS: El id se autoincrementa solo. """
comilla = "`"
campos = db.fields
nombre = comilla + db.name.rstrip(".dbf") + comilla
columnas = []
params = []
for campo in campos:columnas.append(comilla + campo.name + comilla)
params.append("%s")
q = "INSERT INTO %s (%s) VALUES(%s);" % (nombre, ",\n".join(columnas), ",\n".join(params))
return q
# Conexion con el dbf.
db = DBF('r:/prj/fox/sueldos/destino.dbf')
# Conexion con mysql.
datos = [DB_HOST, DB_USER, DB_PASS, DB_NAME]
conn = pymysql.connect(*datos)
cursor = conn.cursor() # Creamos un cursor para insertar los datos.
sql = sql_insert_into(db) # Estructura del INSERT INTO.
# Datos.
for record in db:cursor.execute(sql, tuple(record.values()))
conn.commit()