problem with a select query. Help!

[Juan Alonso]

Hi,

Imagine a simple database with a 'documentos' table.

I have a main class: EjecutarSQL1.java, which calls to a BD class: BD.java, in order to make a query to the database.

The problem is when I try to make a query like
select count(*) from documentos
or like
select distinct name from documentos

The output (the problem) is shown below. The source code at the end of the post.

There are four querys:
- a simple select (that works right)
- one with 'count(*)' (does not work, I get an Invalid cursor state error)
- and other two with 'distinct' (first does not work and the other it does).

Code:

Insert SQL statement (INTRO exits): 
 
select * from documentos
 
 
 
IDDISPONIBLETIPOTITULOAUTOREDICIONEDITORIALFECHAPUBLICACIONFECHAPRESTAMOFECHADEVOLUCIONRESUMENFICHEROWEBSIGNATURASOLOINTERNONOTASIDSUJETOIDENTIDAD
 
 
1nullReligi�n. Teolog�aEL FANTASMA DE LA �PERAnullnullnullnullnullnullEn los
 s�tanos de la �pera de Par�s, entre laber�nticos pasadizos utilizados en 
otro tiempo como prisi�n, un enigm�tico personaje esconde su horrible 
fealdad tras una m�scara. Acecha entre sombras por los camerinos y, sobre 
todo, vigila el escenario cuando act�a Christine, su amor imposible. Tiene 
la esperanza de que si logra atraerla hasta su escondite le liberar� de su 
espantosa condena.nullnullnull0sdfvdsfvfvdsfvdfv7null
 
 
2nullCiencias socialesMIGUEL STROGOFFnullnullnullnullnullnullLa ciudad de 
Irkutsk, capital de la Siberia Oriental, ha quedado incomunicada a causa de 
la sublevaci�n t�rtara. Es necesario que alguien ponga sobre aviso al Gran 
Duque, hermano del Zar, de que el traidor Iv�n Ogareff, instigador del 
levantamiento, pretende atentar contra su vida. Para esta arriesgada misi�n 
eligen a Miguel Strogoff, un correo siberiano. Partir� de Mosc� y atravesar�
 monta�as, estepas y zonas pantanosas en un viaje heroico e 
inici�tico.nullnullnull0null31
 
 
3nullGeneralidadesLa flecha Negranullnullnullnullnullnullnullnullnullnull0null21
 
 
Insert SQL statement (INTRO exits): 
 
select count(*) from documentos
 
 
 
EXPR1000
 
 
3
 
[Microsoft][Administrador de controladores ODBC] Estado del cursor no v�lido
 
 
Insert SQL statement (INTRO exits): 
 
select distinct notas from documentos
 
 
 
[Microsoft][Controlador ODBC Microsoft Access] Instrucci�n SQL no v�lida; se
 esperaba 'DELETE', 'INSERT', 'PROCEDURE', 'SELECT' o 'UPDATE'.
 
 
Insert SQL statement (INTRO exits): 
 
select distinct tipo from documentos
 
 
 
TIPO
 
 
Ciencias sociales
 
Generalidades
 
Religi�n. Teolog�a
 
 
 
-----------------------------------------------------
Here is the code:
 
EjecutarSQL1.java
Code:
 
 package launion.bd;
 
import java.sql.*;
 
import java.io.*;
 
import java.text.SimpleDateFormat;
 
 
import jja.util.bd.BD;
 
 
public class EjecutarSQL1
 
{
 
public static void main(String []args)
 
{
 
BufferedReader teclado=new BufferedReader(new InputStreamReader(System.in));
 
String sql="";
 
ResultSet rs=null;
 
int rows, col;
 
ResultSetMetaData info=null;
 
 
 
BD bd=new BD();
 
try
 
        {
 
            bd.conectar("sun.jdbc.odbc.JdbcOdbcDriver", "jdbc  :-o	  dbc:mydsn", "mylogin", "mypassword");
 
        }
 
        catch(SQLException e1)
 
        {
 
            e1.printStackTrace();
 
        }
 
        catch(ClassNotFoundException e1)
 
        {
 
            e1.printStackTrace();
 
        }
 
 
 
do
 
{
 
System.out.println("\nInsert SQL statement (INTRO exits): ");
 
try
 
{
 
sql=teclado.readLine();
 
if(sql.equals(""))
 
break;
 
 
 
System.out.print("\n\n");
 
 
 
rs=bd.ejecutarRS(sql);
 
info=rs.getMetaData();
 
col=info.getColumnCount();
 
 
 
for(int i=1; i<=col; i++)
 
System.out.print(info.getColumnName(i).toUpperCase()+"\t\t");
 
 
 
System.out.print("\n\n");
 
 
 
while(rs.next())
 
{
 
for(int i=1; i<=col; i++)
 
    System.out.print(rs.getString(i)+"\t");
 
System.out.println();
 
}
 
}
 
catch(Exception e)
 
{
 
System.out.println(e.getMessage());
 
}
 
} while(true);
 
 
 
try
 
{
 
teclado.close();
 
bd.cerrarRS();
 
bd.cerrarStatement();
 
System.out.println("Conexion cerrada");
 
}
 
catch(Exception e)
 
{
 
System.out.println(e.getMessage());
 
}
 
 
}
 
 
} 
 
 
BD.java
Code:
 
 
 
 
package jja.util.bd;
 
import jja.util.java.*;
 
 
import javax.swing.*;
 
import java.sql.*;
 
import java.util.Vector;
 
import java.text.SimpleDateFormat;
 
 
public class BD
 
{
 
String controlador; //p.ej "sun.jdbc.odbc.JdbcOdbcDriver"
 
String ruta; //ruta del origen de datos p.ej "jdbc  :-o	  dbc:BDLaUnion" (BDLaUnion es el origen de datos)
 
Connection conexion;
 
Statement sql;
 
int upd; //valor devuelto por executeUpdate
 
 
String contenido[][]; //de una consulta cualquiera
 
String columnas[]; //de una consulta cualquiera
 
 
ResultSet rs;
 
DatabaseMetaData dbmd;
 
ResultSetMetaData rsm;
 
 
SimpleDateFormat formatoDia=new SimpleDateFormat("dd-MM-yyyy"); //los dias 
se guardan en BD ACCESS con '-', por eso damos salida as�, facilita 
programar las busquedas
 
SimpleDateFormat formatoHora=new SimpleDateFormat("HH:mm:ss"); //los dias se
 guardan en BD ACCESS con ':', por eso damos salida as�, facilita programar 
las busquedas
 
 
public BD()
 
{
 
contenido=null;
 
columnas=null;
 
}
 
 
public void conectar(String controlador, String ruta, String usuario, String psw) throws SQLException, ClassNotFoundException
 
{
 
this.controlador=controlador;
 
this.ruta=ruta;
 
 
Class.forName(controlador);
 
conexion=DriverManager.getConnection(ruta, usuario, psw);
 
}
 
 
public void desconectar() throws SQLException
 
{
 
conexion.close();
 
}
 
 
 
//como el ResultSet se pasa por referencia, se puede cerrar desde fuera y no usar este metodo
 
public void cerrarRS() throws SQLException
 
{
 
rs.close();
 
}
 
 
public void cerrarStatement() throws SQLException
 
{
 
sql.close();
 
}
 
 
//INSERT, UPDATE, DROP, DELETE,... statement or an SQL statement that returns nothing
 
public int ejecutar(String consulta) throws SQLException
 
{
 
//poder recorrer en sentido inverso el rs y resultado de solo lectura
 
sql=conexion.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
 
upd=sql.executeUpdate(consulta);
 
return upd;
 
}
 
 
 
//SELECT
 
public ResultSet ejecutarRS(String consulta) throws SQLException
 
{
 
sql=conexion.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
 
rs=sql.executeQuery(consulta);
 
return rs;
 
}
 
 
 
public JTable ejecutarRS1(String consulta) throws SQLException
 
{
 
    ejecutarRS_Array(consulta);
 
    if(contenido!=null && columnas!=null)
 
        return (new JTable(contenido, columnas));
 
    else
 
        return null;
 
}
 
 
 
public void ejecutarRS_Array(String consulta) throws SQLException
 
{
 
int i=0, j=0, f=0, c=0;
 
 
sql=conexion.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
 
rs=sql.executeQuery(consulta);
 
//c
 
rsm=rs.getMetaData();
 
c=rsm.getColumnCount();
 
 
 
columnas=new String[c];
 
for(j=0; j<c; j++)
 
columnas[j]=new String(rsm.getColumnName(j+1)); //en el rs comenzamos en 1 no en 0
 
 
//f
 
while (rs.next())
 
i++;
 
f=i;
 
contenido=new String[f][];
 
for(i=0; i<f; i++)
 
contenido[i]=new String[c];
 
 
 
//guardar datos consulta en array
 
String cadena=new String();
 
boolean contieneStrHORA=false; //para diferenciar entre time y date el tipo datetime de access
 
 
i=0;
 
rs.beforeFirst();
 
while (rs.next())
 
{
 
for(j=1; j<=c; j++) //empiezo en rsm por el ResultSetMetadata
 
{
 
contenido[i][j-1]=formatearCampoP( columnas[j-1], new String(""+rsm.getColumnType(j)) );
 
//sin testear TIPO DE CAMPO (en el for 0 a c-1)... contenido[i][j]=rs.getString(columnas[j]);
 
}
 
i++;
 
}
 
}
 
 
 
private String formatearCampoP(String c, String tC) throws SQLException
 
{
 
String cadena=new String();
 
boolean contieneStrHORA=false; //para diferenciar entre time y date el tipo datetime de access
 
 
if(String1.buscar(c.toLowerCase(), "hora"))
 
contieneStrHORA=true;
 
 
 
if (Integer.parseInt(tC)==Types.TIMESTAMP && !contieneStrHORA)
 
{
 
try {
 
cadena=(String)formatoDia.format( rs.getDate(c) ); //rs es el ResultSet principal
 
} catch(NullPointerException e) {
 
//cuando hay campos de fecha vacios format() da una NullpointerException
 
cadena="";
 
}
 
}
 
else if (Integer.parseInt(tC)==Types.TIMESTAMP && contieneStrHORA)
 
{
 
try {
 
cadena=(String)formatoHora.format( rs.getTime(c) );
 
} catch(NullPointerException e) {
 
//cuando hay campos de hora vacios format() da una NullpointerException
 
cadena="";
 
}
 
}
 
else if (Integer.parseInt(tC)==Types.BIT)
 
{
 
if(rs.getBoolean(c))
 
cadena="si";
 
else
 
cadena="no";
 
}
 
else //cadena de caracteres
 
cadena=rs.getString(c);
 
 
if(cadena==null)
 
    cadena="";
 
 
 
return cadena;
 
}
 
 
 
 
 
//utilizar despues de cargarArrays() 
 
public String[] getColumnas()
 
{
 
    return columnas;
 
}
 
 
//utilizar despues de cargarArrays() 
 
public String[][] getContenido()
 
{
 
    return contenido;
 
}
 
}
 

And why this code works?. In this case it's only a class: EjecutarSQL.java which querys to the database directly.

Code:

package launion.bd;
 
import java.sql.*;
 
import java.io.*;
 
import java.text.SimpleDateFormat;
 
 
public class EjecutarSQL
 
{
 
public static void main(String []args) 
 
{
 
BufferedReader teclado=new BufferedReader(new InputStreamReader(System.in));
 
String sql="";
 
Connection conexion=null;
 
Statement sentencia=null;
 
ResultSet consulta=null;
 
int lineas, columnas;
 
ResultSetMetaData info=null;
 
 
 
SimpleDateFormat formatoDia=new SimpleDateFormat("dd/MM/yyyy");
 
SimpleDateFormat formatoHora=new SimpleDateFormat("HH:mm:ss");
 
 
 
try
 
{
 
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
 
conexion=DriverManager.getConnection("jdbc  :-o	  dbc:BDLaUnion", "juanjo", "ieeieegestor");
 
sentencia=conexion.createStatement();
 
System.out.println("Conexion establecida");
 
}
 
catch(Exception e)
 
{
 
e.printStackTrace(); 
 
System.out.println("El programa finalizar�");
 
System.exit(1);
 
}
 
 
 
do
 
{
 
System.out.println("\nIntroduzca la sentencia SQL a ejecutar (ENTER para salir): ");
 
 
 
try
 
{
 
sql=teclado.readLine();
 
if(sql.equals(""))
 
break;
 
 
 
System.out.print("\n\n\n");
 
 
 
if(sentencia.execute(sql))
 
{
 
consulta=sentencia.getResultSet();
 
info=consulta.getMetaData();
 
columnas=info.getColumnCount();
 
 
 
for(int i=1; i<=columnas; i++)
 
System.out.print(info.getColumnName(i).toUpperCase()+"\t\t");
 
 
 
System.out.print("\n\n");
 
 
 
while(consulta.next())
 
{
 
for(int i=1; i<=columnas; i++)
 
{
 
System.out.print(consulta.getString(i)+"\t");
 
 
 
}
 
System.out.println();
 
}
 
}
 
else
 
{
 
lineas=sentencia.getUpdateCount();
 
System.out.println("Lineas afectadas: "+lineas);
 
}
 
}
 
catch(Exception e)
 
{
 
System.out.println(e.getMessage());
 
}
 
}
 
while(true);
 
try
 
{
 
teclado.close();
 
conexion.close();
 
System.out.println("Conexion cerrada");
 
}
 
catch(Exception e)
 
{
 
System.out.println(e.getMessage());
 
}
 
 
 
}
 
 
}

Thanks in advance!
Juanjo

[added some line breaks so page doesn't scroll]
[ March 17, 2006: Message edited by: Jeanne Boyarsky ]

[Arul Prasad]

I hope ur using the same connection object for all the queries.It is bad
practise and also for the Prpeared stmt,

Use different connection object and Prepare statement or use the same object and close the object when u executed the each query...

Nice way to close the Conneciton,ResultSet,PreparedStatemnent to close in finally block...

Hope u Got some info related to ur problem ...