import java.sql.*;

import javax.swing.JOptionPane;
import javax.swing.JTextField;

public class DbConnect {
	private Connection con;
	private Statement st;
	private ResultSet rs;
	final int score = 0;

	public DbConnect() {
		try {
			Class.forName("com.mysql.jdbc.Driver");
			con = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "");
			st = con.createStatement();

		} catch (Exception ex) {
			System.out.println("Error: " + ex);

		}
	}

	public void theQuery(String query) {
		Connection con = null;
		Statement st = null;
		try {
			con = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "");
			st = con.createStatement();
			st.executeUpdate(query);
		} catch (Exception ex) {
			JOptionPane.showMessageDialog(null, ex.getMessage());
		}
	}

	public void putData(JTextField username, JTextField password) {
		theQuery("insert persons set name = '" + username.getText() + "',password = '" + password.getText()
				+ "', score = " + score);

	}

	public int getData(JTextField username, JTextField password) {
		int ok = 0;
		try {
			String query = "select * from persons";
			rs = st.executeQuery(query);
			System.out.println("Records from Database");

			while (rs.next()) {
				String name = rs.getString("name");
				String parola = rs.getString("password");

				if (username.getText().equals(name) && password.getText().equals(parola))
					ok = 1;
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
		return ok;
	}

	public int getUsername(JTextField username) {
		int ok = 0;
		try {
			String query = "select * from persons";
			rs = st.executeQuery(query);

			while (rs.next()) {
				String name = rs.getString("name");

				if (username.getText().equals(name))
					ok = 1;
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
		return ok;
	}
}