sql >> Databasteknik >  >> RDS >> Mysql

Skriv DataFrame till mysql-tabellen med pySpark

Så den slutliga koden kan vara

data =['103', 'tester_1']

df = sc.parallelize(data).toDF(['id', 'name'])

df.write.format('jdbc').options(
      url='jdbc:mysql://localhost/database_name',
      driver='com.mysql.jdbc.Driver',
      dbtable='DestinationTableName',
      user='your_user_name',
      password='your_password').mode('append').save()



  1. Så här skapar du en grupperad rapport med hjälp av rapportguiden i Access 2016

  2. Hur man automatiserar migrering (schema och data) för PHP/MySQL-applikationer

  3. MySQL SELECT endast inte null-värden

  4. 900 byte indexstorleksgräns i teckenlängd