Programación JDBC SQL POSTGRES

PROGRAMACION JAVA JDBC POSTGRESQL

---

Autor:Carlos Caceres Ochoa.

Descargar Proyecto Netbeans JDBC POSTGRESQL


Crear Base de Datos Llamado db

---

Tabla Tipo Identificación

CREATE TABLE dbo.tipoidentificacion
(
  id integer NOT NULL,
  tipo character(50),
  CONSTRAINT pk_tipoid PRIMARY KEY (id)

);

---

Tabla Cliente

CREATE TABLE dbo.cliente
(
  numid character(15) NOT NULL,
  tipoid integer,
  primnom character(20),
  segnom character(20),
  primapel character(20),
  segapel character(20),
  direccion text,
  telmovil character(10),
  correo text,
  CONSTRAINT pk_cliente PRIMARY KEY (numid),
  CONSTRAINT fk_tipoid FOREIGN KEY (tipoid)
      REFERENCES dbo.tipoidentificacion (id) MATCH SIMPLE
      ON UPDATE NO ACTION ON DELETE NO ACTION

);

---

PROCEDIMIENTOS DE PRUEBA

---

Procedimiento Suma de Dos Numeros

CREATE OR REPLACE FUNCTION dbo.suma(

    n integer,

    m integer)

  RETURNS integer AS

$BODY$

begin

return n+m;

end

$BODY$

  LANGUAGE plpgsql;

---

Procedimiento Insertar Registro tabla Tipo Identificación

CREATE OR REPLACE FUNCTION dbo.creartipoid(

    ide integer,

    tipoe character)

  RETURNS integer AS

$BODY$

begin

   INSERT INTO dbo.tipoidentificacion(id, tipo)

    VALUES (ide, tipoe);   

    return 1;

exception

    when unique_violation then

        return 0;

end;

 $BODY$

  LANGUAGE plpgsql;

---

Archivo Conexion.java

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.SQLWarning;

public class Conexion
{
    //Objeto Tipo conexion que contiene todos los parametros para interactuar
    //con la BD se crea un objeto tipo con
    public Connection con;

    //Constructor de la clase Conexion que contiene el parametro nombre que determina
    //el nombre de la base de datos que se va ha conectar con el ODBC
    public Conexion()
    {
          try
            {
              //Clase que especifica el nombre de los controladores que se van
              //ha utilizar en la carga de la BD en este caso son los de Access
              Class.forName("org.postgresql.Driver");  //loads the driver
            }
            catch(ClassNotFoundException e)
            {
                    System.out.println("No encontro driver");
            }

            try
            {
                    //url es un texto que contiene la ruta del nombre o la direccion
                    //de coneccion de la base da Datos conectada al JDBC
                    String url = "jdbc:postgresql://localhost:5432/db";
                 
                    //Con es el objeto creado para la coneccion donde se especifican los
                    //parametros de la ubicacion de la BD, login si la base de datos
                    //posee seguridad y por ultimo la clave
                    //DriverManager.getConnection es el servicio que permite establecer
                    //la conexion ABRIR CONEXION!!!
                    con = DriverManager.getConnection(url, "postgres", "123456");

                    //checkForWarning es una funcion que recibe como parametro
                    //el listado de los errores generados en la conexion
                    checkForWarning (con.getWarnings ());
                   
                    //Es un drvie que permite cargar las configuraciones del proveedor
                    //de la BD en este caso las reglas de configuraciones de pOSTgRESS
                    DatabaseMetaData dma = con.getMetaData ();

                   // System.out.println("\nConectado a: " + dma.getURL());
                    //System.out.println("Rurta de la base de datos: "+con."");
                   // System.out.println("Driver       " +   dma.getDriverName());
                   // System.out.println("Version      " +  dma.getDriverVersion());
                   // System.out.println("");

            }
            catch (SQLException ex)
            {
                System.out.println ("\n*** SQLException caught ***\n");

                while (ex != null)
                {
                    System.out.println ("SQLState: " +
                                    ex.getSQLState ());
                    System.out.println ("Message:  " + ex.getMessage ());
                    System.out.println ("Vendor:   " +
                                    ex.getErrorCode ());
                    ex = ex.getNextException ();
                    System.out.println ("");
                }
        }
        catch (java.lang.Exception ex)
        {
            ex.printStackTrace ();
        }
    }

    private static boolean checkForWarning (SQLWarning warn) throws SQLException 
    {
        boolean rc = false;

        if (warn != null)
        {
            System.out.println ("\n *** Warning ***\n");
            rc = true;
            while (warn != null)
            {
                System.out.println ("SQLState: " +warn.getSQLState ());
                System.out.println ("Message:  " +warn.getMessage ());
                System.out.println ("Vendor:   " +warn.getErrorCode ());
                System.out.println ("");
                warn = warn.getNextWarning ();
            }
        }
        return rc;
    }

    public void cerrarConexion()
    {
        try
        {
            //Cierra la conexion de la Base de Datos
            con.close();
            System.out.println("Cerrada la conexion con la Base de Datos");
        }
        catch(SQLException e)
        {
            System.out.println("Error al cerrar la conexion con la Base de datos. \n"+e);
        }
    }
}

---