質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

90.53%

  • Java

    13740questions

    Javaは、1995年にサン・マイクロシステムズが開発したプログラミング言語です。表記法はC言語に似ていますが、既存のプログラミング言語の短所を踏まえていちから設計されており、最初からオブジェクト指向性を備えてデザインされています。セキュリティ面が強力であることや、ネットワーク環境での利用に向いていることが特徴です。Javaで作られたソフトウェアは基本的にいかなるプラットフォームでも作動します。

  • PostgreSQL

    1057questions

    PostgreSQLはオープンソースのオブジェクトリレーショナルデータベース管理システムです。 Oracle Databaseで使われるPL/SQLを参考に実装されたビルトイン言語で、Windows、 Mac、Linux、UNIX、MSなどいくつものプラットフォームに対応しています。

  • AWS Lambda

    50questions

Lambda(java)からRDS(PostgreSQL)にINSERTできない

解決済

回答 1

投稿 編集

  • 評価
  • クリップ 0
  • VIEW 179

atuYamaY

score 119

開発環境

AWS Lambda ランタイム:Java8
aws-lambda-java-core :1.2.0.jar
eclipse version         :Oxygen.3a Release (4.7.3a)
PostgreSQL        :42.2.4.jar
SRE System Library    :JavaSE-1.8

やりたいこと

Lambda 上でjavaを動かし、S3からのイベントを検知してRDS(Postgre)にINSERTしたい

現状

INSERT 用のメソッドがエラーにならず実行されることは確認できたのですが、以下のように、全てNULLの行が挿入されてしまいます。

●テストデータ

{
  "name": "Chris",
  "pass": "XmasParty",
  "age": 20
}

●ソース

public class InsertRecord implements RequestHandler<Request, Response>{
  // 省略:DB接続部分
  public Response handleRequest(Request request, Context context) {
        Response response = new Response();
        try {
            System.out.println(request);

            String sql = "INSERT INTO test(name, pass, age) values(" + request.getName() + ", " + request.getPass() + ", " + request.getAge() + ")";

            conn = DriverManager.getConnection(url, user, pass);
            Statement stmt = conn.createStatement();

            int result = stmt.executeUpdate(sql);

            ResultSet resultSet = stmt.executeQuery("SELECT * FROM test WHERE name = " + request.getName());

            // フィールド一覧を取得
            List<String> fields = new ArrayList<String>();
            ResultSetMetaData rsmd = resultSet.getMetaData();
            for (int i = 1; i <= rsmd.getColumnCount(); i++) {
                fields.add(rsmd.getColumnName(i));
            }

            //結果の出力
            int rowCount = 0;
            while (resultSet.next()) {
                rowCount++;

                System.out.println("---------------------------------------------------");
                System.out.println("--- Rows:" + rowCount);
                System.out.println("---------------------------------------------------");

                //値は、「resultSet.getString(<フィールド名>)」で取得する。
                for (String field : fields) {
                    response.setFields(field, resultSet.getString(field));
                }
            }

            stmt.close();
            conn.close();

        } catch(SQLException e) {
            e.printStackTrace();
        }
        return response;
    }
}

上記のコードは各種Webページを参考にさせていただきながら記述したのですが、
結果は次のようなエラーとなります。

START RequestId: 59f2199d-9072-11e8-8a69-5b2ce4631401 Version: $LATEST
lambda.Request@1f28c152
org.postgresql.util.PSQLException: ERROR: column "chris" does not exist
  Position: 42
    at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2103)
    at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1836)
    at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:257)
    at org.postgresql.jdbc2.AbstractJdbc2Statement.execute(AbstractJdbc2Statement.java:512)
    at org.postgresql.jdbc2.AbstractJdbc2Statement.executeWithFlags(AbstractJdbc2Statement.java:374)
    at org.postgresql.jdbc2.AbstractJdbc2Statement.executeUpdate(AbstractJdbc2Statement.java:302)
    at lambda.InsertRecord.handleRequest(InsertRecord.java:66)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at lambdainternal.EventHandlerLoader$PojoMethodRequestHandler.handleRequest(EventHandlerLoader.java:259)
    at lambdainternal.EventHandlerLoader$PojoHandlerAsStreamHandler.handleRequest(EventHandlerLoader.java:178)
    at lambdainternal.EventHandlerLoader$2.call(EventHandlerLoader.java:888)
    at lambdainternal.AWSLambda.startRuntime(AWSLambda.java:283)
    at lambdainternal.AWSLambda.<clinit>(AWSLambda.java:64)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:348)
    at lambdainternal.LambdaRTEntry.main(LambdaRTEntry.java:94)
END RequestId: 59f2199d-9072-11e8-8a69-5b2ce4631401
REPORT RequestId: 59f2199d-9072-11e8-8a69-5b2ce4631401    Duration: 864.50 ms    Billed Duration: 900 ms     Memory Size: 512 MB    Max Memory Used: 49 MB

上記のエラーの解決方法をご教示いただけますでしょうか。
また、オリジナルのPOJOクラスは以下となりますが、InsertRecordクラスの中に含まなければならない、などの制約はあるのでしょうか。

public class Request {
    String name;
    String pass;
    int age;

    public String getName() {
        return name;
    }
    public String getPass() {
        return pass;
    }
    public String getAge() {
        return String.valueOf(age);
    }

    public void setName(String name) {
        this.name = name;
    }
    public void setPass(String pass) {
        this.pass = pass;
    }
    public void setAge(String age) {
        this.age = Integer.parseInt(age);
    }

    public Request(String name, String pass, String age) {
        this.name = name;
        this.pass = pass;
        this.age = Integer.parseInt(age);
    }
    public Request() {
    }
}

以上です。
よろしくお願いします。

  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 1

check解決した方法

0

自己解決しました。

String sql = "INSERT INTO test(name, pass, age) values(" + request.getName() + ", " + request.getPass() + ", " + request.getAge() + ")";

の部分で、 column does not exist が出ていたので、値が列名として認識されているエラーだと思い色々試していましたが、結局はクォートの問題でした。
(POJOクラスでString型として保持していても、sql文を構成する箇所ではしっかりクォートしてあげないといけないみたいですね。。。)

修正後は以下。

String sql = "INSERT INTO test(name, pass, age) values( '" + request.getName() + "', '" + request.getPass() + "', " + request.getAge() + ")";

分かりづらいですが、name, pass にあたる部分をシングルクォート(' ')で囲んでいます。

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 90.53%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる

関連した質問

同じタグがついた質問を見る

  • Java

    13740questions

    Javaは、1995年にサン・マイクロシステムズが開発したプログラミング言語です。表記法はC言語に似ていますが、既存のプログラミング言語の短所を踏まえていちから設計されており、最初からオブジェクト指向性を備えてデザインされています。セキュリティ面が強力であることや、ネットワーク環境での利用に向いていることが特徴です。Javaで作られたソフトウェアは基本的にいかなるプラットフォームでも作動します。

  • PostgreSQL

    1057questions

    PostgreSQLはオープンソースのオブジェクトリレーショナルデータベース管理システムです。 Oracle Databaseで使われるPL/SQLを参考に実装されたビルトイン言語で、Windows、 Mac、Linux、UNIX、MSなどいくつものプラットフォームに対応しています。

  • AWS Lambda

    50questions