Conexion Java

Descargar como docx, pdf o txt
Descargar como docx, pdf o txt
Está en la página 1de 1

public class Main {

static Connection cn=null;


static BufferedReader br = new BufferedReader(new
InputStreamReader(System.in));
public static void cargarDriver() {
try{
Class.forName("com.mysql.jdbc.Driver");
}catch(ClassNotFoundException e)
{ JOptionPane.showMessageDialog(null,"Error no se puede cargar el
driver:"+e.getMessage());
}
}
public static void conexionBaseDatos() {
try{
String url="jdbc:mysql://localhost:3306/bdejemplo";
String user="root";
String password="";
cn=DriverManager.getConnection(url,user,password);
JOptionPane.showMessageDialog(null,"Conexion Exitosa");
}catch(SQLException e)
{
JOptionPane.showMessageDialog(null,"Error no se puede
puede establecer la conexion"+e.getMessage()); } }
public static void insertarRegistro() throws IOException {
String idproducto,descripcion;
double precio;
int stock;
System.out.print("idproducto : ");
idproducto=br.readLine();
System.out.print("descripcion : ");
descripcion=br.readLine();
System.out.print("precio : ");
precio=Double.parseDouble(br.readLine());
System.out.print("stock : ");
stock = Integer.parseInt(br.readLine());
try{
String sql="insert into
producto(idproducto,descripcion,precio,stock) values (?,?,?,?)";
PreparedStatement ps=cn.prepareStatement(sql);
ps.setString(1,idproducto);
ps.setString(2,descripcion);
ps.setDouble(3, precio);
ps.setInt(4, stock);
ps.executeUpdate();
}catch(SQLException e) {
JOptionPane.showMessageDialog(null,"Error en SQL
"+e.getMessage()); } }
public static void consultaRegistro()throws IOException {
String idproducto,descripcion;
double precio;
int stock;
System.out.print("Id del Producto : ");
idproducto=br.readLine();
try{
String sql = "select * from producto where idproducto=?";
PreparedStatement ps= cn.prepareStatement(sql);
ps.setString(1, idproducto);
ResultSet rs = ps.executeQuery();
if(rs.next())
{
descripcion=rs.getString(2);
precio=rs.getDouble(3);
stock=rs.getInt(4);
System.out.println("Descripcion : "+descripcion);
System.out.println("Precio : "+precio);
System.out.println("Stock : "+stock);
}
else
System.out.println("el idproducto no existe");
}catch(SQLException e) {
System.out.println("Error en SQL "+e.getMessage()); } }
public static void eliminaRegistro() throws IOException {
String idproducto,descripcion;
double precio;
int stock;
System.out.print("Id del Producto : ");
idproducto=br.readLine();
try{
String sql = "delete from producto where idproducto=?";
PreparedStatement ps= cn.prepareStatement(sql);
ps.setString(1, idproducto);
int nro=ps.executeUpdate();

if(nro>0)
{
System.out.println("Se elimino el registro "); }
else
System.out.println("no existe el id ");
}catch(SQLException e) {
System.out.println("Error en SQL "+e.getMessage()); } }
public static void modificaRegistro()throws IOException {
String idproducto,descripcion;
double precio;
int stock;
System.out.print("Id del Producto : ");
idproducto=br.readLine();
try{
String sql = "select * from producto where idproducto=?";
PreparedStatement ps= cn.prepareStatement(sql);
ps.setString(1, idproducto);
ResultSet rs = ps.executeQuery();
if(rs.next())
{
System.out.println("Nueva Descripcion : ");
descripcion=br.readLine();
System.out.println("Nuevo precio : ");
precio=Double.parseDouble(br.readLine());
System.out.println("Nuevo stock : ");
stock=Integer.parseInt(br.readLine());
sql="update producto set descripcion=?, precio=?, stock = ?
where idproducto=?";
ps=cn.prepareStatement(sql);
ps.setString(1,descripcion);
ps.setDouble(2, precio);
ps.setInt(3, stock);
ps.setString(4,idproducto);
ps.executeUpdate();
System.out.println("Se actualizo el producto"); }
else
System.out.println("El idproducto no existe");
}catch(SQLException e)
{
System.out.println("Error en SQL "+e.getMessage()); } }
public static void mostrarTabla()
{
String idproducto,descripcion;
double precio;
int stock;
try{
String sql = "select * from producto";
PreparedStatement ps = cn.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
while(rs.next()) {
idproducto=rs.getString(1);
descripcion=rs.getString(2);
precio=rs.getDouble(3);
stock=rs.getInt(4);
System.out.println(idproducto+", "+descripcion+", "+precio+",
"+stock); }
}catch(SQLException e) {
JOptionPane.showMessageDialog(null,"Error en SQL
"+e.getMessage()); } }
public static void main(String[] args)throws IOException {
cargarDriver();
conexionBaseDatos();
int opcion;
do{
System.out.println("Mantenimiento de Productos");
System.out.println("1) Registrar Productos ");
System.out.println("2) Consultar Productos");
System.out.println("3) eliminar Producto");
System.out.println("4) modificar Producto");
System.out.println("5) mostrar Productos ");
System.out.println("6) Salir");
System.out.print("Ingrese opcion: ");
opcion=Integer.parseInt(br.readLine());
switch(opcion) {
case 1 : insertarRegistro();break;
case 2 : consultaRegistro();break;
case 3 : eliminaRegistro();break;
case 4 : modificaRegistro();break;
case 5 : mostrarTabla();break;
}
}while(opcion!=6); }}

También podría gustarte