Mysql
 sql >> база данни >  >> RDS >> Mysql

Напишете DataFrame в mysql таблица с помощта на pySpark

Така че крайният код може да бъде

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. MySQL заявка за определен период от време

  2. Как да импортирате база данни с помощта на командния ред

  3. REGEXP С PDO Mysql

  4. Защо find_in_set работи, но клауза IN

  5. Резултати от текстовото поле за автоматично довършване на базата на SQL база данни