sql >> Database >  >> RDS >> Mysql

Schrijf DataFrame naar mysql-tabel met behulp van pySpark

Dus de uiteindelijke code zou kunnen zijn

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. Query verwijderen en vernieuwen in ListView in Android (sqlite)

  2. MySQL bestellen voor voor groeperen op

  3. Gebruik NEWID() om een ​​unieke waarde te creëren in SQL Server

  4. Extraheer het jaar van een datum in PostgreSQL