SQLITE_ERROR Ошибка SQL или отсутствует база данных (рядом с «Заявления»: синтаксическая ошибка) - PullRequest
Новая
       1

SQLITE_ERROR Ошибка SQL или отсутствует база данных (рядом с «Заявления»: синтаксическая ошибка)

0 голосов
/ 30 марта 2019

Я пытаюсь применить предотвращение инъекционных атак, используя подготовленные операторы. Мой код настроен так, что у меня есть класс DBManager, который действует как катализатор между Java и sqlite, сохраняя методы java, отвечающие за выполнение операторов sqlite. Затем у меня есть классы таблиц, которые сами хранят операторы sqlite. По сути, я хочу сохранить подготовленный оператор, который выполняет оператор INSERT, и иметь соединение с ним при вызове метода open (). Вот выдержки из двух рассматриваемых классов, в которых я пытаюсь создать подготовленную позицию для константы, хранящейся в классе IncomeStatementTable: 

package com.anniemals.database;

//the database package is meant to be the API package which
// takes all queried values from a database and sets them to values
// in each respective class

//MAKE SURE TO ADD METHODS TO ACCESS DB METADATA, FUNCTIONS, AND VIEWS LATER!
import com.anniemals.clients.ClientInfoIncomeStatement;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class DBManager {

    public static final String DB_NAME = "clients.db";
    public static final String DB_PATH = "jdbc:sqlite:C:/Users/Steven/Documents/ProjectAnnieMalsRemote/Databases/" + DB_NAME;

    //SortOrders for queries
    public static final int ORDER_BY_NONE = 1;
    public static final int ORDER_BY_ASC = 2;
    public static final int ORDER_BY_DESC = 3;

    //Sets a connection to access and utilize sqlite expressions, which are assigned to the PreparedStatement variables for later use
    private Connection conn;

//Inserts
    private PreparedStatement insertIntoIncomeStatementPStatement;
//Composition has-a relationships for Table Classes
    private ClientInfoTable clientInfoTable;
    private IncomeStatementTable incomeStatementTable;

    public DBManager() {
        //Composition has-a relationships for Table Classes
        this.clientInfoTable = new ClientInfoTable();
        this.incomeStatementTable = new IncomeStatementTable();
    }

    public static DBManager getInstance() {
        return instance;
    }

    //Open and Close DB methods

    public boolean open(){
        try{
            conn = DriverManager.getConnection(DB_PATH);
//STATEMENT WHICH CAUSED THE ERROR!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
            insertIntoIncomeStatementPStatement = conn.prepareStatement(incomeStatementTable.getInsertIncomeStatement());
            System.out.println("Database Opened");
            return true;
        } catch (SQLException e){
            System.out.println("Couldn't connect to database: " + e.getMessage());
            e.printStackTrace();
            return false;
        }
    }

    public void close(){
        try {
            if (insertIntoIncomeStatementPStatement != null){
                insertIntoIncomeStatementPStatement.close();
            }
            if(insertIntoClientInfoPStatement != null){
                insertIntoClientInfoPStatement.close();
            }
            if (conn != null){
                conn.close();
                System.out.println("Database closed");
            }
        } catch (SQLException e){
            System.out.println("Couldn't close connection: " + e.getMessage());
        }
    }


public class IncomeStatementTable {

    //Column Labels
    public static final String TABLE_INCOME = "Income Statements";
    public static final String COLUMN_INCOME_ID = "_id";
    public static final String COLUMN_CLIENT_ID = "Client ID";
    public static final String COLUMN_INCOME_DATE = "Date";
    public static final String COLUMN_INCOME_TOTAL_OPER_EXPENSES = "Total Operating Expenses";
    public static final String COLUMN_INCOME_GROSS_PROFIT = "Gross Profit";
    public static final String COLUMN_INCOME_AMORTIZATION = "Amortization";
    public static final String COLUMN_INCOME_EBITDA = "E.B.I.T.D.A.";
    public static final String COLUMN_INCOME_PROFIT_BEFORE_TAX = "Profit Before Tax";
    public static final String COLUMN_INCOME_TAX = "Tax";
    public static final String COLUMN_INCOME_NET_PROFIT = "Net Profit";
    public static final String COLUMN_INCOME_EARN_PER_SHARE = "Earnings Per Share";

    //Column Indexes
    public static final int INDEX_INCOME_ID = 1;
    public static final int INDEX_INCOME_CLIENT_ID = 2;
    public static final int INDEX_INCOME_DATE = 3;
    public static final int INDEX_INCOME_TOTAL_OPER_EXPENSES = 4;
    public static final int INDEX_INCOME_GROSS_PROFIT = 5;
    public static final int INDEX_INCOME_AMORTIZATION = 6;
    public static final int INDEX_INCOME_EBITDA = 7;
    public static final int INDEX_INCOME_PROFIT_BEFORE_TAX = 8;
    public static final int INDEX_INCOME_TAX = 9;
    public static final int INDEX_INCOME_NET_PROFIT = 10;
    public static final int INDEX_INCOME_EARN_PER_SHARE = 11;

public static final String INSERT_INCOME_STATEMENT = "INSERT INTO " + TABLE_INCOME + "(" + COLUMN_INCOME_ID +
            ", " + COLUMN_CLIENT_ID +  ", " + COLUMN_INCOME_DATE  + ", " + COLUMN_INCOME_TOTAL_OPER_EXPENSES
            + ", " + COLUMN_INCOME_GROSS_PROFIT  + ", " + COLUMN_INCOME_AMORTIZATION  + ", " + COLUMN_INCOME_EBITDA
            + ", " + COLUMN_INCOME_PROFIT_BEFORE_TAX  + ", " + COLUMN_INCOME_TAX  + ", " + COLUMN_INCOME_NET_PROFIT
            + ", " + COLUMN_INCOME_EARN_PER_SHARE + ") VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";

    public static String getInsertIncomeStatement() {
        return INSERT_INCOME_STATEMENT;
    }

Я знаю, что это как-то связано с оператором присваивания переменной в методе open (), потому что, когда я его закомментирую, программа работает отлично, и я могу подключиться к базе данных. Я попытался найти ответы на другие вопросы, которые были похожи на мои, здесь, но любые изменения, внесенные мной в синтаксис самого оператора sqlite, все еще оставляют меня с той же ошибкой. Я попытался отследить стек потоков, чтобы увидеть, что означает «Statement» в ошибке, но я все еще не уверен. Может ли кто-нибудь помочь мне определить, где проблема может быть?

Вот стек трассировки: 

org.sqlite.SQLiteException: [SQLITE_ERROR] SQL error or missing database (near "Statements": syntax error)
    at sqlite.jdbc@3.23.1/org.sqlite.core.DB.newSQLException(DB.java:909)
    at sqlite.jdbc@3.23.1/org.sqlite.core.DB.newSQLException(DB.java:921)
    at sqlite.jdbc@3.23.1/org.sqlite.core.DB.throwex(DB.java:886)
    at sqlite.jdbc@3.23.1/org.sqlite.core.NativeDB.prepare_utf8(Native Method)
    at sqlite.jdbc@3.23.1/org.sqlite.core.NativeDB.prepare(NativeDB.java:127)
    at sqlite.jdbc@3.23.1/org.sqlite.core.DB.prepare(DB.java:227)
    at sqlite.jdbc@3.23.1/org.sqlite.core.CorePreparedStatement.<init>(CorePreparedStatement.java:45)
    at sqlite.jdbc@3.23.1/org.sqlite.jdbc3.JDBC3PreparedStatement.<init>(JDBC3PreparedStatement.java:30)
    at sqlite.jdbc@3.23.1/org.sqlite.jdbc4.JDBC4PreparedStatement.<init>(JDBC4PreparedStatement.java:19)
    at sqlite.jdbc@3.23.1/org.sqlite.jdbc4.JDBC4Connection.prepareStatement(JDBC4Connection.java:48)
    at sqlite.jdbc@3.23.1/org.sqlite.jdbc3.JDBC3Connection.prepareStatement(JDBC3Connection.java:263)
    at sqlite.jdbc@3.23.1/org.sqlite.jdbc3.JDBC3Connection.prepareStatement(JDBC3Connection.java:235)
    at sqlite.jdbc@3.23.1/org.sqlite.jdbc3.JDBC3Connection.prepareStatement(JDBC3Connection.java:242)
    at AccountingFinancialModellingAndValuationApplication/com.anniemals.database.DBManager.open(DBManager.java:60)
    at AccountingFinancialModellingAndValuationApplication/com.anniemals.Main.main(Main.java:26)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at javafx.graphics/com.sun.javafx.application.LauncherImpl.launchApplicationWithArgs(LauncherImpl.java:464)
    at javafx.graphics/com.sun.javafx.application.LauncherImpl.launchApplication(LauncherImpl.java:363)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at java.base/sun.launcher.LauncherHelper$FXHelper.main(LauncherHelper.java:1051)

Заранее спасибо тем, кто может помочь.

Ответы [ 2 ]

1 голос
/ 30 марта 2019

Имя таблицы, определяемое этой строкой: 

public static final String TABLE_INCOME = "Income Statements"

содержит пробел, и это не разрешено.
Изменить на это: 

public static final String TABLE_INCOME = "[Income Statements]"

Если имя таблицы или столбца содержит пробелы, его необходимо заключить в квадратные скобки или обратные кавычки (код ASCII 096).
Вы должны сделать то же самое для имен столбцов, содержащих пробелы или точки : 

public static final String TABLE_INCOME = "[Income Statements]";
public static final String COLUMN_INCOME_ID = "_id";
public static final String COLUMN_CLIENT_ID = "[Client ID]";
public static final String COLUMN_INCOME_DATE = "Date";
public static final String COLUMN_INCOME_TOTAL_OPER_EXPENSES = "[Total Operating Expenses]";
public static final String COLUMN_INCOME_GROSS_PROFIT = "[Gross Profit]";
public static final String COLUMN_INCOME_AMORTIZATION = "Amortization";
public static final String COLUMN_INCOME_EBITDA = "[E.B.I.T.D.A.]";
public static final String COLUMN_INCOME_PROFIT_BEFORE_TAX = "[Profit Before Tax]";
public static final String COLUMN_INCOME_TAX = "Tax";
public static final String COLUMN_INCOME_NET_PROFIT = "[Net Profit]";
public static final String COLUMN_INCOME_EARN_PER_SHARE = "[Earnings Per Share]";

Что кажется странным, так это то, что, поскольку вы пытаетесь вставить строки в таблицу, это означает, что вы уже создали таблицу.
Но как?
Какие имена вы использовали для таблицы и столбцов в операторе CREATE?

0 голосов
/ 31 марта 2019

Я нашел решение своей проблемы.Это не самое красивое решение, но оно работает.По сути, я добавил метод create в класс DBManager, как было предложено в forpas: 

 public boolean checkCreateIncomeStatementTable(){
    String sql = "CREATE TABLE IF NOT EXISTS Income_Statements(\n" +
            " _id INTEGER PRIMARY KEY,\n" +
            " Client_ID INTEGER NOT NULL,\n" +
            " Date NUMERAL,\n" +
            " Total_Operating_Expenses DOUBLE NOT NULL,\n" +
            " Gross_Profit DOUBLE NOT NULL,\n" +
            " Amortization DOUBLE NOT NULL,\n" +
            " EBITDA DOUBLE NOT NULL,\n" +
            " Profit_Before_Tax DOUBLE NOT NULL,\n" +
            " Tax DOUBLE NOT NULL,\n" +
            " Net_Profit DOUBLE NOT NULL,\n" +
            " Earnings_Per_Share DOUBLE NOT NULL\n" +
            ");";
    try{
        conn = DriverManager.getConnection(DB_PATH);
        Statement statement = conn.createStatement();
        System.out.println("Database Opened");
        statement.executeQuery(sql);
        System.out.println("Checked creation of Income Statement Table");
        return true;
    } catch (SQLException e){
        System.out.println("Couldn't connect to database: " + e.getMessage());
        e.printStackTrace();
        return false;
    }
}

Затем для каждой метки столбца с пробелами в нем я использовал подчеркивания, так как класс Main не хотел читать скобки длянекоторая причина;

public static final String TABLE_INCOME = "Income_Statements";
public static final String COLUMN_INCOME_ID = "_id";
public static final String COLUMN_CLIENT_ID = "Client_ID";
public static final String COLUMN_INCOME_DATE = "Date";
public static final String COLUMN_INCOME_TOTAL_OPER_EXPENSES = "Total_Operating_Expenses";
public static final String COLUMN_INCOME_GROSS_PROFIT = "Gross_Profit";
public static final String COLUMN_INCOME_AMORTIZATION = "Amortization";
public static final String COLUMN_INCOME_EBITDA = "EBITDA";
public static final String COLUMN_INCOME_PROFIT_BEFORE_TAX = "Profit_Before_Tax";
public static final String COLUMN_INCOME_TAX = "Tax";
public static final String COLUMN_INCOME_NET_PROFIT = "Net_Profit";
public static final String COLUMN_INCOME_EARN_PER_SHARE = "Earnings_Per_Share";

Кажется, теперь все работает

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.

Нет похожих вопросов

...