sábado, 19 de enero de 2013

Clase conexion



import java.util.*;
import java.sql.DriverManager;
import java.sql.Connection;

import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;
/**
 *
 * @author blas
 */
public class conexion {
    private String      user="root";
    private String      password="110185";
    private String      host="localhost";
    private String      database="productos";
    private Connection  conexion    = null;

    public conexion() { }

    public boolean onConnection()
    {
        String cadena="";
        boolean     conectado=false;
     
        conectado=false;
        try
        {
            Properties props = new Properties();
            props.setProperty("user", user);
            props.setProperty("password", password);
            props.setProperty("encoding", "ISO8859_1");

            try{
                Class.forName("com.mysql.jdbc.Driver");
                cadena="jdbc:mysql://"+host+"/"+database;

                conexion = DriverManager.getConnection(cadena, user, password);
                conectado=true;
            } catch (Exception e) {
                conectado=false;
            }
        } catch (Exception e) {
            conectado=false;
        }
        return conectado;
    }
 
    public void offConnection()
    {
        try
        {
            conexion.close();
        } catch (Exception e) { }
    }

    public ResultSet SQLResultSet(String sql) {
        ResultSet   rs = null;
        try
        {
            Statement s = conexion.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
            rs = s.executeQuery(sql);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return rs;
    }
 
    public boolean SQLUpdate(String csql) {
        ResultSet   rs = null;
        String      sql=csql;
        boolean     retorno=false;
        try {
            conexion.setAutoCommit(false);
            try {
                Statement s = conexion.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
                s.executeUpdate(sql);
             
                conexion.commit();
                conexion.setAutoCommit(true);
                retorno=true;

            } catch(SQLException c) {
                conexion.rollback();
                conexion.setAutoCommit(true);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return retorno;
    }
}



<%@ page contentType="text/html" pageEncoding="UTF-8"%>
<%@ page language="java" %> 
<%@ page import = "includes.conexion"%> 
<%@ page import = "java.sql.Statement"%> 
<%@ page import = "java.sql.ResultSet"%> 
<%
    conexion lconexion = new conexion();
    lconexion.onConnection();

    String sql="SELECT id,distrito from distrito order by 2";   
    ResultSet   rs = lconexion.SQLResultSet(sql);
    
    while (rs.next()) {
        out.println(rs.getString("distrito")+"<br>");
    }
 %>

No hay comentarios:

Publicar un comentario