ckR @ brasnet

import java.sql.*;/** * * @author Murilo Adriano */public class AcessoDados {        private Statement dbVar;        /** Creates a new instance of AcessoDados */    public AcessoDados() {               try {            conectarDb();            criarTabelas();        }         catch (SQLException e) {            e.printStackTrace();        }    }        private void conectarDb() throws SQLException {        if (dbVar == null) {            try {                Class.forName("org.hsqldb.jdbcDriver");            }            catch (Exception e) {                System.out.println("Erro ao carregar o driver JDBC.");            }            Connection con = DriverManager.getConnection("jdbc:hsqldb:file:lib/dados/db", "sa", "");             dbVar = con.createStatement();              }    }        private void criarTabelas() {        try {            dbVar.executeQuery("SELECT * FROM clientes LIMIT 1");        }        catch (SQLException e) {            if (e.getErrorCode() == -22) {                try {                    dbVar.executeQuery(                          "CREATE TABLE clientes (" +                        "id INTEGER IDENTITY NOT NULL ," +                        "nome VARCHAR NOT NULL ," +                        "telefone INTEGER NOT NULL ," +                        "endereco VARCHAR NOT NULL ," +                        "setor VARCHAR NOT NULL ," +                        "observacoes VARCHAR NULL )"                    );                }                catch (SQLException ex) {                    ex.printStackTrace();                }            }        }                try {            dbVar.executeQuery("SELECT * FROM setores LIMIT 1");        }        catch (SQLException e) {            if (e.getErrorCode() == -22) {                try {                    dbVar.executeQuery(                          "CREATE TABLE setores ( " +                        "id INTEGER IDENTITY NOT NULL ," +                        "setor VARCHAR NOT NULL ," +                        "taxa INTEGER NOT NULL )"                    );                }                catch (SQLException ex) {                    ex.printStackTrace();                }            }        }    }        public String[] buscarCliente(int telefone) throws SQLException {        ResultSet resultado = dbVar.executeQuery(                "SELECT * FROM clientes WHERE telefone LIKE '" + telefone + "%' limit 1"                );        if (resultado.next()) {            int rsId = resultado.getInt("id");            String rsNome = resultado.getString("nome");            int rsTelefone = resultado.getInt("telefone");            String rsEndereco = resultado.getString("endereco");            String rsSetor = resultado.getString("setor");            String rsObservacoes = resultado.getString("observacoes");                         String rsIdString = Integer.toString(rsId);            String rsTelefoneString = Integer.toString(rsTelefone);                        String[] rs = { rsIdString, rsNome, rsTelefoneString, rsEndereco, rsSetor, rsObservacoes };            return rs;        }        else {            return null;        }      }          public boolean cadastrarCliente(String nome, int telefone, String endereco,             String setor, String observacoes) throws SQLException {            ResultSet rs = dbVar.executeQuery("SELECT * FROM clientes WHERE telefone ='" + telefone + "'");                        if (!rs.next()) {                dbVar.executeQuery("INSERT INTO clientes VALUES (null," +                        "'" + nome + "', " +                        "'" + telefone + "', " +                        "'" + endereco + "', " +                        "'" + setor + "', " +                        "'" + observacoes + "'" +                                                 ")");                return true;            }            else {                return false;            }                  }        public String[] obterSetores() throws SQLException {        ResultSet count = dbVar.executeQuery("SELECT COUNT(*) numLinhas FROM setores");                count.next();        int numLinhas = count.getInt("numLinhas");                ResultSet rs = dbVar.executeQuery("SELECT * FROM setores ORDER BY setor");                int i = 0;        String[] dados = new String[numLinhas];                while (rs.next()) {            dados[i] = rs.getString("setor");            i++;        }                        return dados;    }    public String cadastrarSetor(String setor, int taxa) {        try {            dbVar.executeQuery("INSERT INTO setores VALUES (null, '" + setor + "', '" + taxa + "')");            return "Setor cadastrado com sucesso!";        }        catch (SQLException e) {            e.printStackTrace();            return "Setor não cadastrado.\nCódigo do erro: " + e.getErrorCode() +                     "\n Erro: " + e.getMessage();        }    }}