SQLデータベースエントリを更新しようとすると、SQL構文エラーが発生します。ここで何が問題になっているのかを理解するにはどうすればよいですか?

MYLESMAN

以下は、単純なサーバーに接続して情報などを更新するための私のコードです。

package mysqltest;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class MySQLTest {
    static Connection con = null;
    static Statement stmt = null;
    static ResultSet result = null;

    static String url = "jdbc:mysql://localhost:3306/coffeeshop";
    static String user = "root";
    static String password = "";

    public static void main(String[] args) {                 
            // SQL query string          
            //update specifics
            String push1 = "INSERT INTO Coffees"
                + "(CoffeeName, SupplierID, Price, Sales, Total)"
                + "values"
                + "('Colombian', 95, 5.95, 0, 0)";

            String push2 = "INSERT INTO Coffees"
                + "(CoffeeName, SupplierID, Price, Sales, Total)"
                + "values"
                + "('French Roast', 27, 6.95, 0, 0),"
                + "('Espresso', 104, 7.95, 0, 0),"
                + "('Colombian Decaf', 95, 16.45, 0, 0),"
                + "('French Roast Decaf', 27, 8.45, 0, 0)";

            String push3 = "UPDATE Coffees"
                + "SET SupplierId=12, Total=2"
                + "WHERE CoffeeName='Colombian'";


            String push4 = "DELETE FROM Coffees WHERE CoffeeName='Colombian'";
            String query = "SELECT * FROM Coffees";
            //clear everything first

            //push updates
            connect();
            pushUpdate(push1);
            //need to reconnect after update as update closes connection after updates.
            connect();
            queries(query); 
            pushUpdate(push2);
            connect();
            queries(query);
            pushUpdate(push3);
            connect();
            queries(query);
            pushUpdate(push4);
            connect();
            queries(query);
}
    public static boolean connect(){
        boolean connect;
        try{
            con = DriverManager.getConnection(url, user, password);
            stmt = con.createStatement();
            connect = true;
        }catch(SQLException ex){
            System.out.println("SQLException caught: " + ex.getMessage());
            connect = false;
        }
        return connect;
    }

    public static void pushUpdate(String push){
        try{
            stmt.executeUpdate(push);
        }catch(SQLException ex){
            System.out.println("SQLException caught: " + ex.getMessage());
        }

        try{
            con.close();
            stmt.close();
        }catch(SQLException ex){
            System.out.println("SQLException caught: " + ex.getMessage());   
        }   
    }

    public static void queries(String query){
        try{
            result = stmt.executeQuery(query);
            System.out.printf("%-10s%-35s%-12s  %-9s%-7s%-7s\n", 
                "CoffeeID", "CoffeeName", "SupplierID", "Price", "Sales", "Total");             

            while (result.next()) { // loop until the end of the results                 
                    int coffeeID = result.getInt("CoffeeID");
                    String coffeeName = result.getString("CoffeeName");
                    int supplierID = result.getInt("SupplierID");
                    double price = result.getDouble("Price");
                    int sales = result.getInt("Sales");
                    int total = result.getInt("Total");
                    System.out.printf("%8d  %-35s%10d  %7.2f  %7d%7d\n", coffeeID, coffeeName, supplierID, price, sales, total);
                }

        }catch(SQLException ex){
            System.out.println("Exception caught: " + ex.getMessage());
        }finally {
            try {
                if (result != null) {
                    result.close();
                }
            }catch (SQLException ex){
                System.out.println("SQLException caught: " + ex.getMessage());
            }
        }
    }
}

基本的に、私はすでにテーブルを作成していて、「プッシュ」に従ってテーブルを更新します。プッシュ1、2、および4は正常に機能しますが、3がこのエラーをスローしています...

「SQLExceptionがキャッチされました:SQL構文にエラーがあります。1行目の '= 12、Total = 2WHERE CoffeeName =' Colombian ''の近くで使用する正しい構文については、MariaDBサーバーのバージョンに対応するマニュアルを確認してください。」

さて、基本的には、push3をプログラムに記述し、cmdプロンプトに記述してテストしましたが、正常に動作します。明らかに「+」記号を使用しません。

cmdプロンプトスニペット

デビッド

スペースは重要です。この:

"UPDATE Coffees"
+ "SET SupplierId=12, Total=2"
+ "WHERE CoffeeName='Colombian'"

これになります:

"UPDATE CoffeesSET SupplierId=12, Total=2WHERE CoffeeName='Colombian'"

CoffeesSETは無効で2WHEREあり、無効であるため、ステートメント全体が解析できなくなります。必要な場所にスペースを追加します。

"UPDATE Coffees "
+ "SET SupplierId=12, Total=2 "
+ "WHERE CoffeeName='Colombian'"

この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。

侵害の場合は、連絡してください[email protected]

編集
0

コメントを追加

0

関連記事

TOP 一覧

  1. 1

    PyCharmリモートインタープリターはプロジェクトタブにサイトパッケージのコンテンツを表示しません

  2. 2

    <p:fieldset>の凡例に<h1>、<h2>タグを配置するにはどうすればよいですか?

  3. 3

    セレンのモデルダイアログからテキストを抽出するにはどうすればよいですか?

  4. 4

    パンダは異なる名前の列に追加します

  5. 5

    Railsで宝石のレイアウトを使用するにはどうすればよいですか?

  6. 6

    Java文字列の仕組み

  7. 7

    Chromeウェブアプリのウェブビューの高さの問題

  8. 8

    CSSのみを使用して三角形のアニメーションを作成する方法

  9. 9

    httpListenerコールバックが2回呼び出されます

  10. 10

    Windows 10 Pro 1709を1803、1809、または1903に更新しますか?

  11. 11

    初期化時にextern / static変数のタイプを指定する必要があるのはなぜですか?

  12. 12

    ファイルがgitlfsに正しくアップロードされるかどうかを確認するにはどうすればよいですか?

  13. 13

    Grouping data with datatable with ASP.NET

  14. 14

    Ecto - migrate table column into its own join table (shifting the DATA to the new tables)

  15. 15

    Crashlytics:コンパイラー生成とはどういう意味ですか?

  16. 16

    Python / SciPyのピーク検出アルゴリズム

  17. 17

    PictureBoxで画像のブレンドを無効にする

  18. 18

    ディスパッチ不可能なハンドルが64ビットプラットフォームでptrを使用するのはなぜですか?

  19. 19

    アクティブな管理者で関連するモデルのドロップダウンメニューの問題を解決する方法

  20. 20

    Windows 7では、一部のプログラムは「ビジュアルテーマを無効にする」レジストリ設定を行いませんか?

  21. 21

    文字列内のすべての単語に一致する正規表現

ホットタグ

アーカイブ