Mysql
 sql >> Teknologi Basis Data >  >> RDS >> Mysql

Tulis DataFrame ke tabel mysql menggunakan pySpark

Jadi kode terakhirnya bisa jadi

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. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. PHP PDO dan MySQLi

  2. Penanganan Kegagalan Sementara di .net core 2.1 MVC untuk Database MySQL

  3. Bagaimana cara membuat Django bekerja dengan driver MySQL yang tidak didukung seperti gevent-mysql atau driver MySQL Concurrence?

  4. Bagaimana menemukan dan mengganti teks di tabel mysql

  5. docker-compose:menginisialisasi ulang MySQL db setiap saat