Генерация таблицы Postgresql с использованием Java-аннотаций - PullRequest
Новая
       9

Генерация таблицы Postgresql с использованием Java-аннотаций

0 голосов
/ 01 мая 2018

Я изучаю аннотации и то, как работает hibernate, чтобы лучше понять их.

Я знаю, что мой код может быть не самого лучшего качества, и я исправлю его, когда смогу разрешить свое исключение, я получаю NullPointerException, но не могу понять, почему, что я сделал не так?

Основное в этом классе только там, чтобы найти причину проблемы, у меня есть другой класс, который будет использовать этот, из моего другого класса я могу добавить данные в свою таблицу, но мне нужно иметь возможность создать таблицу, используя аннотации, и вот где я могу получить NullPointerException Я не могу сгенерировать свою таблицу

Это мой StackTrace

Exception in thread "main" java.lang.RuntimeException: java.lang.NullPointerException
at psybergate.grad2018.javafnds.javabasics.annotations.hw3.vendor.DatabaseManager.generateDatabase(DatabaseManager.java:84)
at psybergate.grad2018.javafnds.javabasics.annotations.hw3.vendor.DatabaseManager.main(DatabaseManager.java:40)
Caused by: java.lang.NullPointerException
at psybergate.grad2018.javafnds.javabasics.annotations.hw3.vendor.DatabaseManager.generateDatabase(DatabaseManager.java:82)
... 1 more

Это мой код 

package psybergate.grad2018.javafnds.javabasics.annotations.hw3.vendor;

import java.lang.annotation.Annotation;
import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

import psybergate.grad2018.javafnds.javabasics.annotations.hw3.annotations.DomainClass;
import psybergate.grad2018.javafnds.javabasics.annotations.hw3.annotations.DomainProperty;
import psybergate.grad2018.javafnds.javabasics.annotations.hw3.developer.Customer;

/**
* @since 26 Apr 2018
* @author christiaan.dotze
*/
public class DatabaseManager {

private String addField = "";

private Connection connect = null;

private Statement statement = null;

private String primaryKey = "";

private String tableName = "";

public static void main(String[] args) {
    DatabaseManager manager = new DatabaseManager();
    try {
        Customer cust = new Customer();
        cust.setCustomerNum("11");
        cust.setFirstName("John");
        cust.setLastName("Doe");
        cust.setAge(27);
        cust.setDateOfBirth(1991);

        manager.generateDatabase(cust);
    } catch (ClassNotFoundException | NoSuchFieldException | SecurityException | SQLException ex) {
        throw new RuntimeException("An error occured", ex);
    }
}

public String getTableName(Object obj) {
    Annotation[] domainClassAnnotation = obj.getClass().getDeclaredAnnotations();
    for (Annotation annotation : domainClassAnnotation) {
        if (annotation instanceof DomainClass) {
            tableName = ((DomainClass) annotation).name();
        }
    }
    return tableName;
}

private String getDatabaseFields(Object obj) throws NoSuchFieldException, SecurityException {
    Field[] decladedFields = obj.getClass().getDeclaredFields();
    for (Field field : decladedFields) {
        Annotation[] annotations = field.getDeclaredAnnotations();
        for (Annotation annotation : annotations) {
            if (annotation instanceof DomainProperty) {
                DomainProperty myAnnotation = (DomainProperty) annotation;
                if (myAnnotation.primaryKey() == true) primaryKey = myAnnotation.name();
                if (myAnnotation.unique() == false) {
                    addField += myAnnotation.name() + " " + myAnnotation.dataType() + ",\n";
                } else {
                    addField += myAnnotation.name() + " " + myAnnotation.dataType() + " " + "NOT NULL" + ",\n";
                }
            }
        }
    }
    addField += "PRIMARY KEY(" + primaryKey + ")\n";
    return addField;
}

public void generateDatabase(Object obj)
        throws SQLException, ClassNotFoundException, NoSuchFieldException, SecurityException {
    createConnection();
    getTableName(obj);
    getDatabaseFields(obj);
    try {
        statement.executeUpdate("CREATE TABLE " + getTableName(obj) + "(\n" + getDatabaseFields(obj) + ")");
    } catch (Exception ex) {
        throw new RuntimeException(ex);
    }
}

private void createConnection() throws ClassNotFoundException, SQLException {
    Class.forName("org.postgresql.Driver");
    connect = DriverManager.getConnection("jdbc:postgresql://localhost:5432/", "postgres", "1234");
}

public int add(Object obj, String data)
        throws NoSuchFieldException, SecurityException, SQLException, ClassNotFoundException {
    createConnection();
    statement = connect.createStatement();
    return statement.executeUpdate("INSERT INTO " + getTableName(obj) + " VALUES (" + data + ")");
}
}

1 Ответ

0 голосов
/ 01 мая 2018

У вас есть нулевой объект 'Statement' в методе generateDatabase. Поле «Statement» инициализируется в методе «add», когда «add» никогда не запускается.

Попробуй поставить 

statement = connect.createStatement();

после 

createConnection();

в методе generateDatabase.

...