Esta es mi clase que se encuentra en un paquete, donde tengo un método para la conexion y otro método con el que ejecuto la consulta y recibe como parámetro el query:
package org.COREBITS.prueba.bd;
public class ConexionSQL {
public static Connection con = null;
public static Connection conectar() {
String baseDeDatos = "COREBITS_prueba";
String usuario = "pruebaLogin";
String password = "prueba123";
String url = "jdbc:sqlserver://localhost:1433;databaseName=" + baseDeDatos;
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
} catch (ClassNotFoundException e) {
JOptionPane.showMessageDialog(null, "No se pudo establecer la conexion... revisar el Driver" + e.getMessage(), "Error de Conexion", JOptionPane.ERROR_MESSAGE);
}
try {
con = DriverManager.getConnection(url, usuario, password);
System.out.println("Existosa Conexion a la Base de Datos");
} catch (SQLException e) {
JOptionPane.showMessageDialog(null, "Error:" + e.getMessage(), "Error de Conexion a la BD", JOptionPane.ERROR_MESSAGE);
}
return con;
}
public static ResultSet ejecutarConsulta(String query) {
Connection conn = conectar();
Statement declara;
try {
declara = conn.createStatement();
ResultSet rs = declara.executeQuery(query);
return rs;
} catch (SQLException e) {
JOptionPane.showMessageDialog(null, "Error:" + e.getMessage(), "Error de Conexion al Ejecutar la Query",
JOptionPane.ERROR_MESSAGE);
return null;
}
}
}
y esta dos metodos donde tengo la query de sql para insertar los empleados y otro query para obtenerlos.
package org.COREBITS.prueba.bd;
/**
* Este método crea la consulta SQL que inserta un empleado en la tabla
* empleado de la B.D.
*
* @param emp : El objeto que contiene los datos del empleado a insertar.
* @return
*
*/
public static String insertarEmpleado(empleado emp) {
String query = "INSERT INTO empleado (nombreEmpleado,claveEmpleado,idRol) "
+ "VALUES('" + emp.getNombreEmpleado() + "','"
+ emp.getClaveEmpleado() + "'," + emp.getRol() + ");";
return query;
}
public static String getConsultarEmpleado() {
String consulta = "select emp.*, r.descripcionRol\n"
+ "FROM empleado emp\n"
+ " INNER JOIN Rol r ON emp.idEmpleado=r.idRol";
return consulta;
}
y esta otra clase donde tengo otros métodos para ejecutar las consultas, en el paquete controlador , donde ejecuto la consulta:
package org.COREBITS.prueba.controller;
/**
* Inserta un Empleado en la Base de Datos.
*
* @param emp
* @throws Exception
*/
public void insertarEmpleado(empleado emp) throws Exception {
ConexionSQL conexion = new ConexionSQL();
String query = null;
//Primero abrimos una conexion con la BD:
conexion.conectar();
//Creamos la consulta SQL:
query = CommandsEmpleado.insertarEmpleado(emp);
//Ejecutamos la consulta
conexion.ejecutarQuery(query);
//Cerramos la conexion:
conexion.desconectar();
}
public String[][] consultarTodasLosEmpleados() throws Exception {
//Creamos un objeto de conexion:
ConexionSQL conexion = new ConexionSQL();
//Declaramos el ResultSet:
ResultSet rs = null;
//Declaramos la matriz de datos:
String[][] datos = null;
//Declaramos una variable para
//guardar el numero de renglones:
int renglones = 0;
int renglonActual = 0;
//Establecemos la conexion con la BD:
ConexionSQL.conectar();
//Ejecutamos la consulta y guardamos el resultado en el ResultSet:
Statement stmt = ConexionSQL.con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
rs = stmt.executeQuery(CommandsEmpleado.getConsultarEmpleado());
//Intentamos movernos al ultimo registro:
if (rs.last()) {
renglones = rs.getRow(); //<-Devuelve el numero de registro
datos = new String[renglones][rs.getMetaData().getColumnCount()];
//datos = new String[renglones][5];
}
//Nos movemos al principio del ResultSet:
rs.beforeFirst();
//Iteramos sobre cada registro devuelto:
while (rs.next()) {
datos[renglonActual][0] = "" + rs.getInt("idEmpleado");
datos[renglonActual][1] = "" + rs.getString("nombreEmpleado");
datos[renglonActual][2] = "" + rs.getString("claveEmpleado");
datos[renglonActual][3] = rs.getString("idRol");
datos[renglonActual][4] = rs.getString("descripcionRol");
renglonActual++;
}
//Cerramos el ResultSet:
rs.close();
//Cerramos la conexion:
conexion.desconectar();
//Devolvemos la matriz de datos:
return datos;
}
el problema esta en que cuando hago la consulta para obtener los registros, solo me manda los tres primeros de la tabla que tengo en sql, cuando tengo más de 6
y también cuando inserto un empleado me sale el siguiente error:
com.microsoft.sqlserver.jdbc.SQLServerException: La instrucción no devolvió un conjunto de resultados.
System.out.println
para cada valor que se recupera delResultSet
. En todo caso, no parece un problema del código que muestras. – SJuan76 el 1 ago. 17 a las 18:00