package test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class DbOperations {

	static void deleteClient(int userId) {

		Connection conn = null;
		try {
			conn = DriverManager.getConnection(
					"jdbc:mysql://localhost:3306/products_ex?useSSL=false",
					"root",
					"coderslab"
					);

			String sql = "DELETE FROM products WHERE id=?";
			PreparedStatement ps = conn.prepareStatement(sql);

			ps.setInt(1, userId);

			ps.executeUpdate();

			conn.close();

		} catch(SQLException e) {
			e.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}
	}

	static void addClient(String name, String surname) {

		Connection conn = null;
		try {
			conn = DriverManager.getConnection(
					"jdbc:mysql://localhost:3306/products_ex?useSSL=false",
					"root",
					"coderslab"
					);

			String sql = "INSERT INTO clients(name, surname) VALUES(?, ?)";
			PreparedStatement ps = conn.prepareStatement(sql);

			ps.setString(1, name);
			ps.setString(2, surname);

			ps.executeUpdate();

			conn.close();

		} catch(SQLException e) {
			e.printStackTrace();
		} finally {
			if (conn != null) {
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}
	}

}