Mysql
 sql >> Baza danych >  >> RDS >> Mysql

Zapis DataFrame do tabeli mysql za pomocą pySpark

Więc ostatecznym kodem może być

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.   
  2. Mysql
    3.   
  3. Oracle
    4.   
  4. Sqlserver
    5.   
  5. PostgreSQL
    6.   
  6. Access
    7.   
  7. SQLite
    8.   
  8. MariaDB

  1. Jak używać MySQL z Deno i Oak?

  2. Jak usunąć zduplikowane rekordy w bazie mysql?

  3. MySQL:Odmowa dostępu dla użytkownika 'test'@'localhost' (przy użyciu hasła:TAK) z wyjątkiem użytkownika root

  4. Dlaczego ładowanie obiektów SQLAlchemy za pośrednictwem ORM 5-8x jest wolniejsze niż wierszy za pomocą surowego kursora MySQLdb?

  5. Jak zapętlić zapytanie MySQL przez PDO w PHP?