llamar a funcion creada en musql desde java

[alexander01015]

Saludos a los miembros del foro... Tengo la siguiente funcion lo que hace es devolverme un numero:

Código HTML:

CREATE function NumFilasActividad(fase CHAR(3)) returns INTEGER(3)
BEGIN
	DECLARE num INTEGER(3);
	SELECT COUNT(*) INTO num FROM T_Actividad WHERE Id_Fase=fase;
	return num;
END

Ahora como lo invoco desde java a esa funcion no tengo ni idea de como hacerlo.. de antemano les agradesco por su ayuda..

[hkadejo]

Yo tengo estas funciones

Código Java:

/**
     * @see Object[] parameters = new Object[]{new Integer(0),new
     *      String("CC_TMP_OMISMOR")}; Integer i =
     *      (Integer)executeFunction("{ ? = call p_siit_functions.getNextVal(?) }"
     *      ,parameters);
     * @param cadena
     *            sql y arreglo de parametros
     * @return nothing,
     */
public static Object executeFunction(String sql,
            Object[] params,DataSource dataSource) throws Exception {
                Connection conn = null;
                CallableStatement cstmt = null;
                try {                   
                        Object outPut;
                        conn = dataSource.getConnection();              
                        cstmt = conn.prepareCall(sql);
                
                        if (params != null) {
                                for (int i = 0; i < params.length; i++) {
                                        Object param = params[i];
                                        if (i == 0) {
                                          cstmt.registerOutParameter(1, resolveType(param));
                                        } else {
                                        
                                          cstmt.setObject(i + 1, param, resolveType(param));
                                        }
                                }
                        }               
                        cstmt.execute();        
                        outPut = cstmt.getObject(1);
                                                
                        return outPut;
                } catch (Exception ex) {
                        throw new Exception(ex);
                }finally{
                        if(cstmt!=null){
                                cstmt.close();
                                cstmt = null;
                        }                       
                        if(conn!=null){
                                conn.close();
                                conn = null;
                        }               
                }
}
 
 
private static int resolveType(Object param) {
                int sqlType = Types.VARCHAR;
                if (param == null) {
                    sqlType = Types.NULL;
                } else {
                    Class paramClass = param.getClass();
                    if (param instanceof String) {
                        sqlType = Types.VARCHAR;
                    } else if (paramClass.equals(double.class) ||
                               param instanceof Double) {
                        sqlType = Types.DOUBLE;
                    } else if (param instanceof BigDecimal) {
                        sqlType = Types.NUMERIC;
                    } else if (param instanceof Calendar ||
                               param instanceof java.sql.Date) {
                        sqlType = Types.DATE;
                    } else if (paramClass.equals(int.class) ||
                               param instanceof Integer) {
                        sqlType = Types.INTEGER;
                    } else if (paramClass.equals(long.class) ||
                               param instanceof Long) {
                        sqlType = Types.BIGINT;
                    } else if (paramClass.equals(float.class) ||
                               param instanceof Float) {
                        sqlType = Types.REAL;
 
                    }
                }
                return sqlType;
}
 

Esta hecho para correr con una base de datos Oracle, pero ya lo he probado en MySQL con un proyecto personal y me corrio muy bien, espero te sirva.

[alexander01015]

Hola hkadejo hice lo siguiente aunque igual le falta algo porq me sale cero es como si no ejecutara pienso que le falta algo q estoy pasando por alto haber si hechas una mano

Código HTML:

static public String CountFilas(String filas) {
       String mensaje=null;
       int numero=0;
        try {
            ConectaDB db = new ConectaDB();
            Connection cn = db.getConnection();
 
            if (cn == null) {
                mensaje = "No hay conexión a la base de datos...!";
            } else {
                Statement st = cn.createStatement();
          
                CallableStatement sp_CountFilas=cn.prepareCall("{call NumFilasActividad(?)}");
                
                sp_CountFilas.registerOutParameter(1,Types.CHAR);
                
                sp_CountFilas.execute();
                
                numero=sp_CountFilas.getInt(1);
               
                st.close();
                cn.close();
            }
        } catch (SQLException e) {
            mensaje=null;
        } catch (Exception e) {
            mensaje=null;
        }
        
 
        return String.valueOf(numero);
              
    }
 

Te lo agradeceria mucho....

[hkadejo]

Iniciado por alexander01015

Hola hkadejo hice lo siguiente aunque igual le falta algo porq me sale cero es como si no ejecutara pienso que le falta algo q estoy pasando por alto haber si hechas una mano

Código HTML:

static public String CountFilas(String filas) {
       String mensaje=null;
       int numero=0;
        try {
            ConectaDB db = new ConectaDB();
            Connection cn = db.getConnection();
 
            if (cn == null) {
                mensaje = "No hay conexión a la base de datos...!";
            } else {
                Statement st = cn.createStatement();
          
                CallableStatement sp_CountFilas=cn.prepareCall("{call NumFilasActividad(?)}");
                
                sp_CountFilas.registerOutParameter(1,Types.CHAR);
                
                sp_CountFilas.execute();
                
                numero=sp_CountFilas.getInt(1);
               
                st.close();
                cn.close();
            }
        } catch (SQLException e) {
            mensaje=null;
        } catch (Exception e) {
            mensaje=null;
        }
        
 
        return String.valueOf(numero);
              
    }
 

Te lo agradeceria mucho....

Dos cosas que veo dandole un vistazo a tu codigo

1) El string de tu funcion debe ser algo asi: "? = call p_siit_functions.getNextVal(?)" si te fijas hay un primer simbolo de interrogacion que es donde se guardara el parametro de salida, tienes que ponerselo.


2) La siguiente linea

Código Java:

sp_CountFilas.registerOutParameter(1,Types.CHAR);
 

Ahi deberia definir un tipo numerico, no un char...el parametro de salida que registres debe ser congruente con el tipo que devuelve tu funcion.

[alexander01015]

Hola hkadejo hice los cambios pero aun persite me sigue saliendo 0:

Código HTML:

static public Integer CountFilas(String filas) {
       String mensaje=null;
       int numero=0;
        try {
            ConectaDB db = new ConectaDB();
            Connection cn = db.getConnection();
 
            if (cn == null) {
                mensaje = "No hay conexión a la base de datos...!";
            } else {
                Statement st = cn.createStatement();
          
                CallableStatement sp_CountFilas=cn.prepareCall("{? = call NumFilasActividad(?)}");
                
                sp_CountFilas.registerOutParameter(1,Types.INTEGER);
                
                sp_CountFilas.setString(2, filas);
                                               
                 sp_CountFilas.executeQuery();
                 
                numero=sp_CountFilas.getInt(1);
                 
                
                st.close();
                cn.close();
            }
        } catch (SQLException e) {
            mensaje=null;
        } catch (Exception e) {
            mensaje=null;
        }
        
 
        return numero;
              
    }
 

Haber hechale otro vistazo... gracias por ayudarme con este problema...

[harkonen]

Si te da 0 es que debe estar saltando una excepción en el try-catch.

¿Puedes poner que te retorna la excepción?

[alexander01015]

Gracias hkadejo... era el tipo de dato lo que estaba mal y eso era lo que hacia que retorne 0... ahora funciona de maravilla gracias a todos...