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

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

ただいまの
回答率

88.78%

TCP/IPで受信したデータをMySQLに格納する

受付中

回答 1

投稿 編集

  • 評価
  • クリップ 0
  • VIEW 1,770

toukibi

score 27

前提・実現したいこと

Android端末とPC間でTCP通信を行い、受信したものをデータベースに格納するプログラムを開発したいのですが、うまくいきません。UDP通信も試したのですがそちらではうまく格納できました。
内容は変わっていないはずなのですがうまくいかない理由がさっぱり非常に困っています。どうか助けてください。
エラー文ではデータ容量が設定より多いという意味のようですが、UDPで格納できた時と送信しているものは変えていいませんし、テーブルのカラムもいじっていません。
TCP通信を通すとデータ量が変わるなどがあるのでしょうか?
格納しているデータはAndroid端末が取得したアクセスポイント情報で、MACアドレスやSSID,電波強度などの情報です。
それをsplitで分割して、配列の番号で振り分けて代入しているというものです。
どうぞよろしくお願いいたします。

発生している問題・エラーメッセージ

com.mysql.jdbc.MysqlDataTruncation: Data truncation: Data too long for column 'tateyoko' at row 1
    at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3868)
    at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3806)
    at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2470)
    at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2617)
    at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2546)
    at com.mysql.jdbc.StatementImpl.executeUpdateInternal(StatementImpl.java:1541)
    at com.mysql.jdbc.StatementImpl.executeLargeUpdate(StatementImpl.java:2605)
    at com.mysql.jdbc.StatementImpl.executeUpdate(StatementImpl.java:1469)
    at sqls.MServer.run(TCPWrite.java:78)

ソースコード

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class TCPWrite {
    public static final int SERVER_PORT = 5431;
    public static final int PACKET_SIZE = 1024;

    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(SERVER_PORT);
            System.out.println("WriteServerが起動しました(port="
                        + serverSocket.getLocalPort() + ")");
            while (true) {
                Socket socket = serverSocket.accept();
                new MServer(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                if (serverSocket != null) {
                    serverSocket.close();
                }
            } catch (IOException e) {}
        }
    }

}

class MServer extends Thread {
    private static final int BUFSIZE = 1024; // 受信バッファサイズ
    private Socket socket;

    private static String url = "jdbc:mysql://192.168.82.89:3306/wifi_db";
    private static String driver = "com.mysql.jdbc.Driver";
    private static String id = "wifi";
    private static String pass = "neuro";
    private static Statement st;
    private static String msg = "scan_tbl";


    public MServer(Socket socket) {
        this.socket = socket;
        //System.out.println("接続されました "
          //            + socket.getRemoteSocketAddress());
    }

    public void run() {
        try {
            int rcevsize;
            byte[] buf = new byte[BUFSIZE];
            InputStream in = socket.getInputStream();
            OutputStream out = socket.getOutputStream();
            Class.forName(driver);
            Connection con = DriverManager.getConnection(url,id,pass);
            st = con.createStatement(); 
            while ((rcevsize = in.read(buf)) != -1) {
                String str = new String(buf);
                 System.out.println(str);
                 if(str.equals(msg)){
                        String sql = "TRUNCATE " + str ;
                        st.executeUpdate(sql);
                        System.out.println("テーブル " + str +" の中身を削除しました");
                 }else{
                     String wifi[] = str.split(",");
                     String sql = "INSERT INTO " + "`"+wifi[0]+"`" +"(`macaddress`,`ssid`,`level`,`time`,`coord`,`direction`,`angle`,`tateyoko`)"
                             + "VALUES('" + wifi[1] + "','" + wifi[2] + "','" + wifi[3] + "','"+ wifi[4] + "','"  + wifi[5] + "','" + wifi[6] + "','"+ wifi[7]+ "','"+ wifi[8] +"')";
                     st.executeUpdate(sql);
                     out.write(buf, 0, buf.length);
                 }
            }
        }catch (IOException e) {
            e.printStackTrace();
        }catch(SQLException e){
            e.printStackTrace();
        }catch(ClassNotFoundException e){
            System.out.println("ドライバが見つかりません");
        }finally {
            try {
                if (socket != null) {
                    socket.close();
                }
            } catch (IOException e) {
            System.out.println("切断されました "
                    + socket.getRemoteSocketAddress());
            }
        }
    }

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

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

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

    クリップを取り消します

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

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

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

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

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

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

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

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

    質問の評価を下げる

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

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

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

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

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

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

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

    詳細な説明はこちら

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

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

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

回答 1

0

'tateyoko' カラムに対して、定義したサイズより大きいデータで登録したから、このエラーが出てます。
テーブル定義とwifi[8]の値を確認してください。

投稿

  • 回答の評価を上げる

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

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

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

  • 回答の評価を下げる

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

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

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

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

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

関連した質問

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