package main.resources.domain.receiver;

import main.resources.persistency.DynamicDao;
import main.resources.persistency.DynamicDaoOracle;

import java.sql.SQLException;

public class ExecuteService {

    /**
     * Executes given SQL code on given database
     * @param code SQL query to be executed
     * @param databaseType
     * @param url of the database
     * @return true if code was successfully executed, false if not
     */
    public boolean executeCode(String code, String databaseType, String url, String username, String password)
            throws ClassNotFoundException, SQLException {
        DynamicDao dynamicDao;

        if(databaseType.toUpperCase().equals("ORACLE")) {
            dynamicDao = new DynamicDaoOracle();
        } else {
            System.out.println("Invalid or unsupported database type");
            return false;
        }

        dynamicDao.setTargetUrl(url);
        dynamicDao.setTargetUsername(username);
        dynamicDao.setTargetPassword(password);

        return dynamicDao.executeCode(code);
    }
}