lemfo
New Contributor II
df = spark.read.format('parquet').load(path = datasource_path)
df = df.select("*").toPandas()
df.to_sql('users', conn, if_exists='replace', index = False)