JDBC y HSQLDB: crear bases de datos con Java y el motor de base de datos de OpenOffice

19 10 2009

HSQLDB es un sistema de bases de datos relacional SQL escrito en Java, de unos 600 kb usado por aplicaciones como OpenOffice. Dispone de un controlador JDBC y ofrece un pequeño y rápido sistema de bases de datos que gestiona tablas basadas en disco y memoria con un modo servidor y embebido, además de incluir un pequeño servidor web, herramientas de manejo y de consulta basadas en memoria que pueden correr en forma de aplicaciones.

En Ubuntu para usuarlo es necesario instalar el servidor hsqldb:

^?Descargar instalar-hsqldb.txt

1	sudo apt-get install hsqldb-server

A continuación expondré un pequeño ejemplo no muy sofisticado para mostrar un posible uso básico. Presupongo un cierto conocimiento en Java y de bases de datos, asi como del lenguaje SQL.

Explicare unas breves líneas de cada parte del código sin profundizar demasiado, ya que el código esta bastante estructurado y es casi auto-explicativo para alguien que tenga ciertos conocimientos en la materia.

También ciertas partes del código o mensajes están en inglés, esto es así, porque generalmente estoy acostumbrado a hacerlo de tal modo (y para mí es una buena práctica de uso hacerlo), de todas formas no es un inglés demasiado complicado.

^?Descargar BDprac.java

import java.io.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
 
import java.util.Properties;
 
public class BDprac
{
    static Connection con  = null;
    static Statement  st   = null;  
    static ResultSet  res  = null; 
    static String     sql  = null;
    private static final String DBH = "jdbc:hsqldb:file:src/bd";
    // With memory: "jdbc:hsqldb:mem:bdname"
 
    public static void main(String args[]) throws IOException
    {
        loadHSQLDB();
        connectDB();
        createStatement();
        dropTables();
        createTables();
        restoreDB();
        menu();
        closeHSQLDB();
    }
 
    public static void loadHSQLDB()
    {
        System.out.println("* Starting...");
        try
        {
            Class.forName("org.hsqldb.jdbcDriver"); //Load HSQLDB driver
            System.out.println("* Loading HSQLDB driver...");
        } 
        catch(Exception e)
        {  
            System.err.println("ERROR: failed to load HSQLDB JDBC driver.");
            e.printStackTrace();
            return;  
        } 
    }
 
    public static void connectDB()
    {
        try
        {   // Connect to the database or create if it don't exist 
            con = DriverManager.getConnection(DBH); 
            System.out.println("* Creating HSQLDB connection...");
        }
        catch(Exception e)
        {
            System.err.println("Error: " + e.getMessage());
            return;
        }
    }
 
    public static void createStatement()
    {
        try
        {
            st  = con.createStatement(); 
        }
        catch (Exception e)
        {  
            System.err.println("Error: createStatement: " + e.getMessage());   
            return;
        }
    }
 
    public static void dropTables()
    {
        try 
        {   // Drop tables
            st.executeUpdate("DROP TABLE IF EXISTS stusub;DROP TABLE IF EXISTS student;DROP TABLE IF EXISTS subject;");
            System.out.println("* Drop table if exists...");
        }
        catch (Exception e)
        {  
            System.err.println("Warning: drop table: " + e.getMessage());   
        }  
    }
 
    public static void createTables()
    {
        try 
        {   // Create tables
            sql = "CREATE TABLE student ( " +
                                            "id         INTEGER NOT NULL PRIMARY KEY, " +
                                            "name       VARCHAR(25) NOT NULL, " +
                                            "lastname   VARCHAR(100), " +
                                            "address    VARCHAR(100), " +
                                            "city       VARCHAR(100), " +
                                            "pcode      VARCHAR(5), " +
                                            "email      VARCHAR(80), " +
                                            "mobile     VARCHAR(50), " +
                                            "subject VARCHAR(40)," +
                                            "CONSTRAINT UNIQUE_STU UNIQUE(name)" +
                                         ");";  
            st.executeUpdate(sql);  
            System.out.println("* Creating student table...");
 
            sql = "CREATE TABLE subject ( " +
                                            "id         INTEGER NOT NULL PRIMARY KEY, " +
                                            "name       VARCHAR(100) NOT NULL, " +
                                            "CONSTRAINT UNIQUE_SUB UNIQUE(name)" +
                                         ");";  
            st.executeUpdate(sql);  
            System.out.println("* Creating subject table...");
 
            sql = "CREATE TABLE stusub ( " +
                                            "id             INTEGER NOT NULL PRIMARY KEY, " +
                                            "subject        INTEGER NOT NULL, " +
                                            "student       INTEGER NOT NULL, " +
                                            "FOREIGN KEY (student) REFERENCES student(id), " +
                                            "FOREIGN KEY (subject) REFERENCES subject(id), " +
                                            "CONSTRAINT UNIQUE_STUSUB UNIQUE(subject, student)" +
                                         ");";  
            st.executeUpdate(sql);  
            System.out.println("* Creating student-subject table...");
        } 
        catch (Exception e)
        {  
            System.err.println("Warning: CREATE TABLE: " + e.getMessage());   
        }
    }
 
    public static void restoreDB()
    {
        try 
        {   // Restore the database  
            st.executeUpdate("DELETE FROM stusub;DELETE FROM student;DELETE FROM subject;");
            System.out.println("* Restore the original databases, removing all previous inserting data.");
        }
        catch (Exception e)
        {  
            System.err.println("Warning: error on vacuum tables: " + e.getMessage());   
        } 
    }
 
    public static void menu()
    {
        boolean exit = false;
        boolean insert = false;
        int option;
 
        while(!exit)
        {
            System.out.println("\t.: Menu :.\n" +
                               "\t0 - Salir\n" +
                               "\t1 - Insertar alumnos y asignaturas por defecto.\n" +
                               "\t2 - Modificar el nombre de una asignatura (0 - Literatura).\n" +
                               "\t3 - Consultar alumnos por apellido.\n" +
                               "\t4 - Listar todos los alumnos.\n" +
                               "\t5 - Listar todas las asignaturas.\n"
                               );  
 
            try
            {        
                System.out.print("Introduzca una opción numérica:");
                option = Integer.parseInt(read());                   
            }
            catch(NumberFormatException ex){
                System.out.println("La opción no es un número.");
                option = -1;
            }
 
            switch(option)
            {
                case 0:
                    exit = true;
                break;
                case 1:
                    if(!insert)
                    {
                        insertData();
                        insert = true;
                        System.out.println("Datos correctamente insertados.\n");
                    }
                    else System.out.println("Datos ya insertados previamente.\n");
                break;
                case 2:
                    if(!insert)
                    {
                        System.out.println("Deben insertarse datos previamente.");
                    }
                    else
                    {
                        System.out.print("Introduzca el nuevo nombre para la asignatura 'Literatura':");
                        updateSubject(read());
                    }
                break;
                case 3:
                    if(!insert)
                    {
                        System.out.println("Deben insertarse datos previamente.");
                    }
                    else
                    {
                        System.out.print("Introduzca el apellido a consultar:");
                        showSubjectByLastName(read());
                    }
                break;
                case 4:
                    if(!insert)
                    {
                        System.out.println("Deben insertarse datos previamente.");
                    }
                    else
                    {
                        showStudents(); 
                    }
                break;
                case 5:
                    if(!insert)
                    {
                        System.out.println("Deben insertarse datos previamente.");
                    }
                    else
                    {
                        showSubjects();
                    }
                break;
                default:
                    System.out.println("Opcion incorrecta.\n");
                break;
            }
        }
    }
 
    public static void closeHSQLDB()
    {
        // Save temporal data and close
        try
        {
            st = con.createStatement();  
            st.executeUpdate("SHUTDOWN");  
            st.close(); 
        }
        catch(Exception e)
        {
            System.out.println("Error: save temporal data" + e.getMessage());
        }
 
        try
        {
            con.close();
        }
        catch(Exception e)
        {
            System.out.println("Error: " + e.getMessage());
            e.printStackTrace();
            return; 
        }
    }
 
    public static String read()
    {
        try
        {
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            return br.readLine();
        }
        catch(Exception e)
        { 
            System.out.println("Error en la lectura de datos:\n");
            e.printStackTrace();
            return "";
        }
    }
 
    public static void insertData()
    {
        // Insert data  
        try 
        { 
            //Insert subject
            st.executeUpdate("INSERT INTO subject VALUES ('0', 'Literatura')");  
            st.executeUpdate("INSERT INTO subject VALUES ('1', 'Ciencia')");  
            st.executeUpdate("INSERT INTO subject VALUES ('2', 'Redes')");  
 
            //Insert student
            st.executeUpdate("INSERT INTO student VALUES ('0', 'Juan', 'Garrido', 'Sol, 12', 'Sevilla', '13206', 'j.garrido@gmail.com', '609555321', '0')");  
            st.executeUpdate("INSERT INTO student VALUES ('1', 'Luis', 'Garrido', 'Flor, 5', 'Melilla', '43712', 'l.garrido@gmail.com', '615827343', '0')");  
            st.executeUpdate("INSERT INTO student VALUES ('2', 'Teresa', 'Garcia', 'Mata, 18', 'Madrid', '28045', 'tere.garcia@gmail.com', '678123687', '1')");  
 
            //Foreign keys stusub
            st.executeUpdate("INSERT INTO stusub VALUES ('0', '0', '0')");  
            st.executeUpdate("INSERT INTO stusub VALUES ('1', '0', '1')");  
            st.executeUpdate("INSERT INTO stusub VALUES ('2', '1', '2')");  
        }
        catch (Exception e)
        {  
            System.err.println("Warning: error on insert data: " + e.getMessage());   
            e.printStackTrace();
            return; 
        } 
    }
 
    public static void showStudents()
    {
        try 
        { 
            // Mostramos por pantalla todos los alumnos de la tabla  
            res = st.executeQuery("SELECT * FROM student INNER JOIN subject ON student.subject = subject.id");  
            System.out.println("ID\tNombre\tApellido Direccion\tCiudad\tCodigo Postal\t\tEmail\t\tMovil\t\tAsignatura\n" + 
                               "-------------------------------------------------------------------------------------------" + 
                               "--------------------------");  
            while (res.next())
            {  
                System.out.println(res.getInt("id") + "\t" + 
                                   res.getString("name") + "\t" + 
                                   res.getString("lastname") + "\t " + 
                                   res.getString("address") + "\t" + 
                                   res.getString("city") + "\t" + 
                                   res.getString("pcode") + "\t\t" + 
                                   res.getString("email") + "\t" + 
                                   res.getString("mobile") + "\t" + 
                                   res.getString("subject"));
            }
 
            // Free memory
            res.close(); 
        }
        catch (Exception e)
        {  
            System.err.println("Warning: SELECT JOIN student: " + e.getMessage());   
        }
    }
 
    public static void showSubjectByLastName(String lastname)
    {
        try 
        { 
            // Mostramos por pantalla todos los alumnos de la tabla  
            res = st.executeQuery("SELECT * FROM student WHERE lastname = '" + lastname + "'");  
            System.out.println("ID\tNombre\tApellido Direccion\tCiudad\tCodigo Postal\t\tEmail\t\tMovil\t\tAsignatura\n" + 
                               "-------------------------------------------------------------------------------------------" + 
                               "--------------------------");  
            while (res.next())
            {  
                System.out.println(res.getInt("id") + "\t" + 
                                   res.getString("name") + "\t" + 
                                   res.getString("lastname") + "\t " + 
                                   res.getString("address") + "\t" + 
                                   res.getString("city") + "\t" + 
                                   res.getString("pcode") + "\t\t" + 
                                   res.getString("email") + "\t" + 
                                   res.getString("mobile") + "\t" + 
                                   res.getString("subject"));
            }
 
            // Free memory
            res.close(); 
        }
        catch (Exception e)
        {  
            System.err.println("Warning: SELECT lastname student: " + e.getMessage());   
        }
    }
 
    public static void showSubjects()
    {
        try 
        { 
            // Mostramos por pantalla todos las asignaturas de la tabla  
            res = st.executeQuery("SELECT * FROM subject");  
            System.out.println("ID\tNombre\n" + 
                               "--------------------");  
            while (res.next())
            {  
                System.out.println(res.getInt("id") + "\t" + 
                                   res.getString("name")
                                   );
            }
 
            // Free memory
            res.close(); 
        }
        catch (Exception e)
        {  
            System.err.println("Warning: SELECT subject: " + e.getMessage());   
        }
    }
 
    public static void updateSubject(String data)
    {
        // Make a update
        try 
        { 
            st.executeUpdate("UPDATE subject SET name='" + data + "' WHERE id=0");  
        }
        catch (Exception e)
        {  
            System.err.println("Warning: UPDATE subject: " + e.getMessage());   
        } 
    }
}

De la linea 1 a 7 se cargan los archivos necesarios para el funcionamiento del programa.

La linea 9 crea la clase BDprac. En ella tenemos unas variables globales a la clase desde la línea 11 a 14, que serán utilizadas para las posteriores consultas y resultados.

La línea 15 es interesante porque especifica el DBH (Data-Base-Host), es decir, el enlace o ruta hasta nuestra base de datos. En nuestro caso sera un archivo local, y primero invocaremos al controlador jdbc, seguido de hsqldb e indicaremos que es un archivo en la ruta src/ y con el nombre bd. Tambien es posible crear la base de datos en memoria como esta comentado en la linea 16.

En las líneas 18-28 tenemos el main, donde se han encapsulado en una serie de métodos todo el funcionamiento del programa (por resultar más didáctico).

Los métodos estan dispuestos en orden en el codigo asi que paso a comentarlos brevemente.

loadHSQLDB() de la línea 30 a 44, se encarga de inicializar o cargar el controlador JDBC y mostrar un mensaje en caso de fallo.

connectDB() de la línea 46 a 58, se encarga de conectar el controlador HSQLDB a nuestro DBH en la base de datos.

createStatement() de la línea 60 a 71, prepara una consulta a la base de datos.

dropTables() de la línea 73 a 84, hace una limpieza inicial (borra si existen) de las tablas que hayan podido usarse en ejecuciones anteriores del programa (para evitar conflictos con antiguas insercciones).

createTables() de la línea 86 a 128, crea tres tablas, alumnos, asignaturas y la tabla de referencias ajenas alumnos-asignatura.

restoreDB() de la línea 130 a 141 borra los posibles datos que existieran en las tablas anteriores.

menu() de la línea 143 a 231, contiene el uso del programa, la lectura de opciones y filtrado de acciones segun el parámetro elegido.

closeHSQLDB() de la línea 233 a 257, se encarga de cerrar la conexión HSQLDB y finalizar las consultas abiertas. Es ejecutada al finalizar el programa.

read() de la línea 259 a 272, es un método encargado de la lectura de datos de entrada.

insertData() de la línea 274 a 300, inserta los datos iniciales en la tablas del programa a modo de ejemplo.

showStudents() de la línea 302 a 331, muestra todos los alumnos disponibles en la tabla students.

showSubjectByLastName() de la línea 333 a 362, muestra los alumnos que coincidan en apellido con el filtro de apellido recibido por parámetro lastname.

showSubjects() de la línea 364 a 386, lista todas las asignaturas disponibles en la tabla subjects.

updateSubject() de la línea 388 a 399, actualiza el nombre de la asignatura 0 (Literatura) al nombre recibido por parámetro data.

Para que la compilación y la ejecución resulte más sencilla, he preparado un archivo Makefile, que establecerá la ruta de HSQLDB y de nuestro directorio de trabajo (y ademas con clean, tiene una opción de borrado de archivos generados):

^?Descargar Makefile.txt

JAVA_PATH = src/:/usr/share/java/hsqldb.jar:.
BOLD = \033[1m
END  = \033[0m
 
all:
    @echo "$(BOLD)>>> Compilando archivos Java... < <<$(END)"
   javac src/BDprac.java 
 
    @echo "\n$(BOLD)>>> Ejecutando archivos Java... < <<$(END)"
    java -classpath $(JAVA_PATH) BDprac
 
clean:
   $(RM) src/*.class src/*~ src/*.script src/*.properties

Ejemplos de uso

El programa carga el controlador y realiza una conexión HSQLDB a un archivo de base de datos creado en tiempo de ejecución (también se puede crear un archivo en memoria, ver línea 16 comentada en el código). Se crean las tablas iniciales (alumno y asignaturas) y una tabla para las claves ajenas. También se procede al borrado y vaciado de datos, por si la aplicación ha sido iniciada anteriormente (a modo de limpieza).

Posteriormente aparecerá un menú con algunas opciones básicas. Si pretendemos hacer alguna operación sin insertar datos previamente, se nos mostrará un mensaje (por ejemplo metiendo la opción 3 al inicio).

Después de insertar los datos, podemos hacer una consulta de todos los alumnos, eligiendo la opción 4.

Si deseamos cambiar el nombre de una asignatura (para el ejemplo siempre la 0, de Literatura), elegiremos la opción 2, e introduciremos el nuevo nombre (en este caso Arte). Y con la opción 5 podremos listar las asignaturas antes y después del cambio.

Con la opción 3, podemos consultar los alumnos por nombre de apellido, por ejemplo, introduciendo “Garrido” se listan los alumnos con apellido Garrido. Y con 0 finalizaremos la ejecución del programa.

Ejemplo de una traza de ejecución

^?Descargar traza.txt

$ make
>>> Compilando archivos Java... < <<
javac src/BDprac.java 
 
>>> Ejecutando archivos Java... < <<
java -classpath src/:/usr/share/java/hsqldb.jar:. BDprac
* Starting...
* Loading HSQLDB driver...
* Creating HSQLDB connection...
* Drop table if exists...
* Creating student table...
* Creating subject table...
* Creating student-subject table...
* Restore the original databases, removing all previous inserting data.
  .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:3
Deben insertarse datos previamente.
    .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:1
Datos correctamente insertados.
 
    .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:4
ID Nombre  Apellido Direccion  Ciudad  Codigo Postal       Email       Movil       Asignatura
---------------------------------------------------------------------------------------------------------------------
0    Juan    Garrido  Sol, 12    Sevilla 13206       j.garrido@gmail.com 609555321   0
1  Luis    Garrido  Flor, 5    Melilla 43712       l.garrido@gmail.com 615827343   0
2  Teresa  Garcia   Mata, 18   Madrid  28045       tere.garcia@gmail.com   678123687   1
   .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:
La opción no es un número.
Opcion incorrecta.
 
    .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:5
ID Nombre
--------------------
0 Literatura
1 Ciencia
2    Redes
   .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:2
Introduzca el nuevo nombre para la asignatura 'Literatura':Arte
  .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:5
ID Nombre
--------------------
0 Arte
1   Ciencia
2    Redes
   .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:3
Introduzca el apellido a consultar:Garrido
ID   Nombre  Apellido Direccion  Ciudad  Codigo Postal       Email       Movil       Asignatura
---------------------------------------------------------------------------------------------------------------------
0    Juan    Garrido  Sol, 12    Sevilla 13206       j.garrido@gmail.com 609555321   0
1  Luis    Garrido  Flor, 5    Melilla 43712       l.garrido@gmail.com 615827343   0
   .: Menu :.
  0 - Salir
   1 - Insertar alumnos y asignaturas por defecto.
 2 - Modificar el nombre de una asignatura (0 - Literatura).
 3 - Consultar alumnos por apellido.
 4 - Listar todos los alumnos.
   5 - Listar todas las asignaturas.
 
Introduzca una opción numérica:0

Si lo deseas, puedes descargar el ejemplo completo en un archivo empaquetado y comprimido con Gzip en formato tar.gz:

Descargar: java-jdbc-hsqldb-openoffice-example.tar.gz (56)

Nota: todos los datos de alumnos de este artículo son ficticios.

Rating: 9.0/10 (2 votes cast)

Rating: 0 (from 0 votes)

Comparte, descargalo en pdf, imprimelo o enviaselo a un amigo!

Entradas relacionadas:

Crear paquetes DEB de código Python en Ubuntu

Acciones

Informaciones

Fecha : 19 Octubre 2009
Categorías: Ingeniería del software , Java , Open Source , Ubuntu , Universidad

4 comentarios

At 2009.11.07 18:48, Cristian said:

Excelente post, de verdad! Sencillamente genial…

Ahora mismo le hago un tweet para promoverlo…

Un saludo!
UN:F [1.8.3_1051]

espera por favor...

Rating: 8.0/10 (1 vote cast)

UN:F [1.8.3_1051]

Rating: 0 (from 0 votes)

[Reply]
At 2009.11.08 03:36, shakaran said:

@Cristian: Gracias Me alegro que te haya gustado.
UA:F [1.8.3_1051]

espera por favor...

Rating: 0.0/10 (0 votes cast)

UA:A [1.8.3_1051]

Rating: 0 (from 0 votes)

[Reply]
At 2009.11.10 09:28, uberVU - social comments said:

Social comments and analytics for this post…

This post was mentioned on Twitter by casidiablo: JDBC y HSQLDB: crear bases de datos con Java y el motor de base de datos de OpenOffice http://tinyurl.com/ycwnsc8...
UN:F [1.8.3_1051]

espera por favor...

Rating: 0.0/10 (0 votes cast)

UN:F [1.8.3_1051]

Rating: 0 (from 0 votes)

[Reply]
At 2009.11.11 18:27, Aldo said:

excelente…a probar
UN:F [1.8.3_1051]

espera por favor...

Rating: 0.0/10 (0 votes cast)

UN:F [1.8.3_1051]

Rating: 0 (from 0 votes)

[Reply]

Shakaran