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

スパークデータフレームをpostgresデータベースに書き込む

    write.jdbcを試して、write.jdbc()の外部で個別に作成されたパラメーターを渡します。また、postgresが書き込みに使用できるポートがPostgres 9.6の場合は5432、Postgres8.4の場合は5433であることを確認します。

    mode = "overwrite"
    url = "jdbc:postgresql://198.123.43.24:5432/kockpit"
    properties = {"user": "postgres","password": "password","driver": "org.postgresql.Driver"}
    data.write.jdbc(url=url, table="test_result", mode=mode, properties=properties)
    


    1. MySQLクエリを使用して、テーブル全体のテキストを検索して置換します

    2. すでに定義されている環境変数にputenv()が必要なのはなぜですか?

    3. MySQL:10分より古いすべての行を削除します

    4. xbuildとmonoを使用すると、EntityFrameworkメタデータアーティファクトが埋め込まれません