sql >> データベース >  >> RDS >> Mysql

pySparkを使用してDataFrameをmysqlテーブルに書き込みます

    したがって、最終的なコードは次のようになります

    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. データベース管理、分析、セキュリティに関するRavenDBのOrenEiniへのインタビュー

    2. OpenCart1.5でのデータベースバックアップの復元

    3. SSISパッケージを使用してSQLServerからExcelおよびテキストファイルにデータをエクスポートする

    4. 週番号から週の開始日と終了日を取得します