问题：

将Java类连接到Derby数据库可提高池连接的性能

芮琛

2023-03-14

我有一个名为ConnectionDerby的类，在该类中，我设置了连接到嵌入式数据库（Derby）的参数，我想减少连接的冗余度，实际的方法和连接可以工作，但我想提高性能，因此该类的代码如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.swing.JOptionPane;

public class ConnectionDerby {

    private Connection conn = null;
    private Statement sttm = null;

    public Connection CrearBD(String query) {
        try {
        //Obtenemos el Driver de Derby
        Class.forName("org.apache.derby.jdbc.EmbeddedDriver");
        conn = DriverManager.getConnection("jdbc:derby:.\\BD\\inventario.db;create=true");
        if (conn != null) {
            //JOptionPane.showMessageDialog(null, "Base de Datos Lista");
            try {
                PreparedStatement pstm = conn.prepareStatement(query);
                pstm.execute();
                pstm.close();
                //JOptionPane.showMessageDialog(null, "Base de Datos Creada Correctamente");
                System.out.println("SENTENCIA SQL EFECTUADA CORRECTAMENTE");
            } catch (SQLException ex) {
                //JOptionPane.showMessageDialog(null, ex.getLocalizedMessage());
                System.out.println(ex.getMessage());
                JOptionPane.showMessageDialog(null, "NO SE PUDO EFECTUAR LA SENTENCIA SQL", "Error", JOptionPane.ERROR_MESSAGE);
                //JOptionPane.showMessageDialog(null, "NO SE PUDO EFECTUAR LA SENTENCIA SQL");
            }
        }

        } catch (SQLException e) {
        System.out.println(e.getMessage());
        JOptionPane.showMessageDialog(null, "NO SE PUDO EFECTUAR LA SENTENCIA SQL", "Error", JOptionPane.ERROR_MESSAGE);
        //JOptionPane.showMessageDialog(null, "TRONO LA APLICACION EN EJECUTAR LAS SENTENCIAS SQL parte 2");
    } catch (ClassNotFoundException e) {
        System.out.println(e.getMessage());
        JOptionPane.showMessageDialog(null, "NO SE PUDO EFECTUAR LA SENTENCIA SQL", "Error", JOptionPane.ERROR_MESSAGE);
        //JOptionPane.showMessageDialog(null, "TRONO LA APLICACION EN EJECUTAR LAS SENTENCIAS SQL parte 3");
    }
        return conn;
    }

    public Connection AccederBD() {
        try {
            //Obtenemos el Driver de Derby
            Class.forName("org.apache.derby.jdbc.EmbeddedDriver");
            //Obtenemos la Conexión
            conn = DriverManager.getConnection("jdbc:derby:.\\BD\\inventario.db");
            if (conn != null) {
                System.out.println("Base de Datos Ya Leida Correctamente");
                //JOptionPane.showMessageDialog(null, "Base de Datos Ya Leida Correctamente");
            }
        } catch (SQLException e) {
            System.out.println(e.getMessage());
            System.out.println("NO SE ENCONTRO LA BASE DE DATOS");
            System.out.println("CREANDO BASE DE DATOS EN DERBY DATABASE");
            String createTableProyecto = "CREATE TABLE proyecto\n"
                + "(\n"
                + "idproyecto INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1),\n"
                + "nombre VARCHAR(50) NOT NULL,\n"
                + "descripcion VARCHAR(1000),\n"
                + "CONSTRAINT proyecto_pk PRIMARY KEY (idproyecto)\n"
                + ")";
            String createTablePrimera = "CREATE TABLE primera\n"
                + "(\n"
                + "idprimera INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1),\n"
                + "nombre VARCHAR(75) NOT NULL,\n"
                + "descripcion VARCHAR(1000),\n"
                + "CONSTRAINT primera_pk PRIMARY KEY (idprimera)\n"
                + ") ";
            String createTableSegunda = "CREATE TABLE segunda\n"
                + "(\n"
                + "idsegunda INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1),\n"
                + "nombre VARCHAR(75) NOT NULL,\n"
                + "descripcion VARCHAR(1000),\n"
                + "CONSTRAINT segunda_pk PRIMARY KEY (idsegunda)\n"
                + ")";
            String createTableEncabezado = "CREATE TABLE encabezado\n"
                + "(\n"
                + "idencabezado INTEGER NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 1, INCREMENT BY 1),\n"
                + "idproyecto INTEGER NOT NULL,\n"
                + "idprimera INTEGER NOT NULL,\n"
                + "idsegunda INTEGER NOT NULL,\n"
                + "fecha DATE NOT NULL,\n"
                + "CONSTRAINT encabezado_pk PRIMARY KEY (idencabezado)\n"
                + ")";
            String createRelationCotizacionIdTopCoat = "ALTER TABLE ENCABEZADO ADD FOREIGN KEY (IDSEGUNDA) REFERENCES SEGUNDA(IDSEGUNDA)";
            String createRelationCotizacionIdPrimer = "ALTER TABLE ENCABEZADO ADD FOREIGN KEY (IDPRIMERA) REFERENCES PRIMERA(IDPRIMERA)";
            String createRelationCotizacionIdProyecto = "ALTER TABLE ENCABEZADO ADD FOREIGN KEY (IDPROYECTO) REFERENCES PROYECTO(IDPROYECTO)";
            CrearBD(createTableProyecto);
            CrearBD(createTablePrimera);
            CrearBD(createTableSegunda);
            CrearBD(createTableEncabezado);
            CrearBD(createRelationCotizacionIdTopCoat);
            CrearBD(createRelationCotizacionIdPrimer);
            CrearBD(createRelationCotizacionIdProyecto);
            //*************PRUEBAS*****************
        } catch (ClassNotFoundException e) {
            System.out.println(e.getMessage());
            System.out.println("ERROR DE TIPO ClassNotFoundException");
            //JOptionPane.showMessageDialog(null, "TRONO LA APLICACION EN ACCEDER A LA BASE DE DATOS parte 2");
        }
        return conn;
    }

    public void UID(String sqlcad) {
        try {
            //Obtenemos el Driver de Derby
            Class.forName("org.apache.derby.jdbc.EmbeddedDriver");
            conn = DriverManager.getConnection("jdbc:derby:.\\BD\\inventario.db");
            sttm = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
            sttm.executeUpdate(sqlcad);
            System.out.println("Conexión Exitosa a la Base de Datos");
            //JOptionPane.showMessageDialog(null, "Conexión exitosa");
            sttm.close();
            conn.close();
            if (conn != null) {
            System.out.println("Consulta Realizada Correctamente");
            //JOptionPane.showMessageDialog(null, "Base de Datos Ya Leida Correctamente");
            }
        } catch (SQLException e) {
            System.out.println("Error= " + e.getMessage());
        } catch (ClassNotFoundException e) {
            System.out.println("Error= " + e.getMessage());
        }
    }

    public ResultSet getvalores(String sqlcad) {
        ResultSet rs = null;
        try {
        Class.forName("org.apache.derby.jdbc.EmbeddedDriver");
        conn = DriverManager.getConnection("jdbc:derby:.\\BD\\inventario.db");
        sttm = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
        //String sqlcad = "Select nombre, descripcion from primera";
        rs = sttm.executeQuery(sqlcad);
        return rs;
        } catch (Exception e) {
            System.out.println("Error= " + e.getMessage());
            return rs;
        }
    }
}

我使用另一个类来设置查询的字符串，如下所示：

import java.sql.ResultSet;

public class Primer {

    ConnectionDerby c = new ConnectionDerby();

    public void insertMaestroPrimera(String nombre, String descripcion) {
        c.UID("INSERT INTO primera(nombre, descripcion) values('" + nombre + "','" + descripcion + "')");
    }

    public void updateMaestroPrimera(int id, String nombre, String descripcion) {
        c.UID("UPDATE primera set nombre='" + nombre + "',descripcion='" + descripcion + "' where idprimera=" + id);
    }

    public void deleteMaestroPrimer(int id) {
        c.UID("DELETE FROM primera where idprimera=" + id);
    }

    public ResultSet llenarTable() {
        ResultSet rs = null;
        String sql = "SELECT nombre, descripcion from primera ORDER BY nombre";
        rs = c.getvalores(sql);
        return rs;
    }

    public ResultSet obtenerDatos(String value) {
        ResultSet rs = null;
        String sql = "SELECT idprimera, nombre, descripcion from primera WHERE nombre = '" + value + "'";
        rs = c.getvalores(sql);
        return rs;
    }
}

所以伙计们，我想要一些建议，因为当我在表encabezado中进行更新时，我遇到了以下错误：“Error=Statement.executeUpdate（）无法使用返回ResultSet的语句调用。”和“Error=无法在请求的时间内获得锁”。我认为这是因为池连接太多，所以请任何人都可以帮助我提高性能，或者也许sql是错误的，我不知道，但其他表（primera、segonda、proyecto）中的CRUD工作得很好！顺便感谢您的时间！

乜思淼

2023-03-14

你目前的设计有两个大问题：

每个方法必须在本地声明连接变量。您将连接声明为一个字段，因此，如果两个线程同时访问同一个ConnectionDerby对象实例执行不同操作，则会陷入竞争状态，从而出现奇怪的问题，如此错误消息中发布的错误：error=Statement。不能使用返回结果集的语句调用executeUpdate（），这意味着线程a尝试在同一时间对同一实例执行更新，线程B尝试在同一时间对同一实例执行读取操作，并且竞争条件混合了连接和语句实例。

您正在手动打开连接。这是一个坏主意，因为打开连接在性能方面成本很高。您应该改用数据库连接池。

话虽如此，您可以通过以下方式提高项目的性能并解决项目中的问题：

使用数据库连接池。有几个选项，我建议使用BoneCP

更多信息：

如何从JBoss中打开的连接池中正确保持DB连接
数据库连接应该一直保持打开状态，还是只在需要时打开

您可能没有使用JBoss，但答案中的概念也适用于这种情况。

将Java类连接到Derby数据库可提高池连接的性能

共有1个答案

相关问答

相关文章

相关阅读

相关工具

相关文档