以下は、単純なサーバーに接続して情報などを更新するための私のコードです。
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プロンプトに記述してテストしましたが、正常に動作します。明らかに「+」記号を使用しません。
スペースは重要です。この:
"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]
コメントを追加