4

Tengo una base de datos en PostgreSql 9.3 la cual contiene tres tablas sin vínculos entre ellas (como llaves foráneas). A esta base de datos se conectan dos aplicaciones en Java 8 que corren una en un cliente y otra en el servidor donde está la BD. La aplicación en el servidor necesita saber si se está modificando sólo una de las tablas de la BD.

Estuve jugando con el código de esta web, y pude recibir notificaciones en mi aplicación de ejemplo, incluso enviándolas desde la ventana de scripts sql del pgAdmin III simplemente ejecutando "Notify mymessage" (en mi caso, funcionó sin necesidad de hacer "Select 1").

Lo bueno de este método es que bastaría que la aplicación cliente envíe notificaciones cada vez que modifica la tabla que le interesa a la aplicación en el servidor.

Lo malo de este método es que la aplicación en el servidor no sabe qué registro se está modificando, insertando o eliminando.

¿Hay alguna manera de enviar, junto a la notificación, datos como la clave primaria del registro involucrado?

1

2 respuestas 2

3

Una vez tuve el mismo problema, la solución a la que llegue fue utilizar un trigger para INSERT y UPDATE que enviaba algo así:

PERFORM pg_notify('nombredetabla', NEW.campoidentificador);

Luego, escuchando el canal nombredetabla, recibía las notificaciones de los registros y mirando el payload sabia que registro fue actualizado.

2
  • 1
    por cierto, lo mismo funciona para DELETE pero hay que usar OLD en lugar de NEW Commented el 17 dic. 2015 a las 22:02
  • Tengan cuidado con la sentencia PERFORM que ignora las excepciones y condiciones de error que pueda lanzar la función llamada (en este caso pg_notify) Commented el 18 dic. 2015 a las 15:57
3

for the completeness:

Se pueden enviar notificaciones con más información usando la instrucción de Postgres:

select pg_notify('canal_a_escuchar', 'cadena con datos');

La condición es que la app que recibe las notificaciones debe mantener una conexión abierta todo el tiempo:

Connection conn = DriverManager.getConnection(...);
org.postgresql.PGConnection pgconn = (org.postgresql.PGConnection)conn;
Statement stmt = conn.createStatement();
stmt.execute("LISTEN canal_a_escuchar");
stmt.close();

Y cada tanto debe pedir las notificaciones con:

pgconn.getNotifications();

Fuente: https://jdbc.postgresql.org/documentation/80/listennotify.html

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.