Juan Alonso

Greenhorn

+ Follow

news 1 Posts 1 Threads

since Mar 15, 2006

Merit badge: grant badges

For More

Cows and Likes

Cows

Total received

In last 30 days

Forums and Threads

Recent posts by Juan Alonso

problem with a select query. Help!

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 ]

18 years ago

JDBC and Relational Databases