import javax.servlet.*; import javax.servlet.http.*; import java.sql.*; import java.io.*; public class SqlSelect extends HttpServlet { Connection cone = null; String resposta; public void doPost( HttpServletRequest request, HttpServletResponse response ) throws ServletException, IOException { PrintWriter output = response.getWriter(); response.setContentType( "text/html" ); try { //Conexão com o banco String usuario = request.getParameter( "user" ); String senha = request.getParameter( "pass" ); Class.forName( "org.gjt.mm.mysql.Driver" ); cone = DriverManager.getConnection( "jdbc:mysql://localhost/scec", usuario, senha ); String command = request.getParameter( "command" ); boolean success = selectDB( command ); if ( success ) { output.println( resposta ); } else { output.print( "\n" ); output.print( "\n" ); output.print( "Erro na Procura...\n" ); output.print( "\n" ); output.print( "\n" ); output.print( "\n" ); output.print( "

Ocorreu um erro, tente novamente !!

\n" ); output.print( resposta ); output.close(); } } catch ( Exception e ) { output.print( "\n" ); output.print( "\n" ); output.print( "\n" ); output.print( "\n" ); output.print( "\n" ); output.print( "\n" ); output.print( "

Ocorreu um erro, tente novamente !!

\n" ); output.print( e.getMessage() ); output.close(); } } private boolean selectDB( String executecommand ) { try { Statement stmt = cone.createStatement(); int cont = 0; if ( stmt.execute( executecommand ) ) cont = 1; StringBuffer buf = new StringBuffer(); buf.append( "\n" ); buf.append( "Resultado da Procura\n" ); buf.append( "\n" ); buf.append( "\n" ); buf.append( "\n" ); buf.append( "\n" ); if ( cont == 1 ) { ResultSet resultado = stmt.getResultSet(); buf.append( "

Resultado da procura....

\n" ); buf.append( "--> " + executecommand + "

" ); ResultSetMetaData rsmd = resultado.getMetaData(); buf.append( "Nome da Tabela: " + rsmd.getTableName( 1 ) + "
\n" ); buf.append( "" ); for ( int i = 1; i <= rsmd.getColumnCount(); ++i ) buf.append( "" ); while ( resultado.next() ) { buf.append( "" ); for ( int i = 1; i <= rsmd.getColumnCount(); ++i ) buf.append( "" ); buf.append( "" ); } buf.append( "

" + rsmd.getColumnName( i ) + "

" + resultado.getString( i ) + "

Comando Concluído !!" ); resposta = buf.toString(); stmt.close(); cone.close(); } else { buf.append( "--> " + executecommand + "

Comando Concluído !!" ); resposta = buf.toString(); cone.close(); } } catch ( Exception e ) { StringBuffer buf = new StringBuffer(); buf.append( "Motivo do Erro: " + e.getMessage() ); resposta = buf.toString(); return false; } return true; } public void destroy() { try { cone.close(); } catch ( Exception e ) { System.err.println( "Problemas em fechar o banco" ); } } }