Baze

package podaci;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.HashMap;

import javax.swing.JFrame;
import javax.swing.JOptionPane;


public abstract class Baze
{
    private static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
    private static final String DB_URL = "jdbc:mysql://localhost:3306/osobe";
    private static final String USER = "root";
    private static final String PASS = "12345";

    private static Connection conn = null;
    private static java.sql.Statement stmt = null;
    private static ResultSet rs = null;
    private static PreparedStatement preparedStatement = null;

    private static void close()
    {
        try
        {
            if(conn != null)
            {
                conn.close();
            }

            if(stmt != null)
            {
                conn.close();
            }

            if(rs != null)
            {
                rs.close();
            }

            if(preparedStatement != null)
            {
                preparedStatement.close();
            }
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }

    private static void start(boolean ind, String sql)
    {
        try
        {
            conn = DriverManager.getConnection(DB_URL, USER, PASS);
            stmt = conn.createStatement();
            if(ind == true)
            {
                rs = stmt.executeQuery(sql);
            }
            else
            {
                preparedStatement = conn.prepareStatement(sql);
            }
        }
        catch(Exception e)
        {
            e.printStackTrace();
            JOptionPane.showMessageDialog(new JFrame(), "Nemogu�a konencija sa bazom!", "Gre�ka", JOptionPane.ERROR_MESSAGE);
            System.exit(0);
        }
    }

    public static HashMap<Integer, Osoba> iscitaj()
    {
        HashMap<Integer, Osoba> mapa = new HashMap<Integer, Osoba>();
        try
        {
            Class.forName(JDBC_DRIVER);

            String sql = "select osoba.idOsoba, osoba.ime, osoba.prezime, osoba.godine from osoba";
            start(true, sql);

            while(rs.next())
            {
                int id = rs.getInt("osoba.idOsoba");
                String ime = rs.getString("osoba.ime");
                String prezime = rs.getString("osoba.prezime");
                int godine = rs.getInt("osoba.godine");

                mapa.put(id, new Osoba(ime, prezime, godine));
            }
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            close();
        }

        return mapa;
    }

    public static void upisi(Osoba u)
    {
        try
        {
            Class.forName(JDBC_DRIVER);

            String sql = "insert into osoba(osoba.ime, osoba.prezime, osoba.godine) values(?, ?, ?)";
            start(false, sql);

            preparedStatement.setString(1, u.getIme());
            preparedStatement.setString(2, u.getPrezime());
            preparedStatement.setInt(3, u.getGodine());
            preparedStatement.execute();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            close();
        }
    }

    public static void izmeni(HashMap.Entry<Integer, Osoba> par)
    {
        try
        {
            Class.forName(JDBC_DRIVER);

                String sql = "update osoba set ime = ?, prezime = ?, godine = ? where idOsoba = ?";
                start(false, sql);

                preparedStatement.setString(1, par.getValue().getIme());
                preparedStatement.setString(2, par.getValue().getPrezime());
                preparedStatement.setInt(3, par.getValue().getGodine());
                preparedStatement.setInt(4, par.getKey());
                preparedStatement.execute();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            close();
        }
    }

    public static void obrisi(HashMap.Entry<Integer, Osoba> par)
    {
        try
        {
            Class.forName(JDBC_DRIVER);

            String sql = "delete from osoba where idOsoba = ?";
            start(false, sql);

            preparedStatement.setInt(1, par.getKey());
            preparedStatement.execute();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            close();
        }
    }
}