public class Conectar {
private Statement declaracion = null;
private ResultSet resultado = null;
public Connection conectar()
{
String url = "jdbc:mysql://localhost/NOMBREBDD";
String driver = "org.gjt.mm.mysql.Driver";
String login = "root";
String clave = "admin";
Connection conexion = null;
try {
Class.forName(driver);
try {
conexion = (Connection) DriverManager.getConnection(url, login, clave);
if(conexion != null)
System.out.println("Coneccion lista");
} catch (SQLException ex) {
System.out.println("Error en conexión");
}
} catch (ClassNotFoundException ex) {
System.out.println(ex);
}
return conexion;
}
public int grabar(String sqlString)
{
int hayError = 0;// error
try {
declaracion = conectar().createStatement();
hayError = declaracion.execute(sqlString) ? 1 : 0;
} catch (SQLException ex) {
System.out.println("Error en coneccion (GRABAR)");
}
finally
{
try {
conectar().close();
} catch (SQLException ex) {
Logger.getLogger(Conectar.class.getName()).log(Level.SEVERE, null, ex);
}
}
return hayError;
}
public ResultSet consutar(String sqlString)
{
try {
declaracion = conectar().createStatement();
resultado = declaracion.executeQuery(sqlString);
} catch (SQLException ex) {
resultado = null;
}
return resultado;
}
public DefaultTableModel listar(String sqlString)
{
DefaultTableModel modelo = new DefaultTableModel();
try
{
resultado = consutar(sqlString);
if (resultado == null)
return modelo;
ResultSetMetaData columnas = resultado.getMetaData();
int canColumnas = columnas.getColumnCount();
for(int i= 1; i<=canColumnas; i++)
modelo.addColumn(columnas.getColumnLabel(i));
Object[] fila = new Object[canColumnas];
do
{
for(int i = 0; i < canColumnas; i++)
fila[i] = resultado.getObject(i+1);
modelo.addRow(fila);
}while(resultado.next());
resultado.close();
}
catch (Exception ex)
{
System.out.println("error en el llenado de la tabla");
}
return modelo;
}
}