import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Scanner;


class viseKorisnika1 {
	static {
		try {
			Class.forName("com.ibm.db2.jcc.DB2Driver");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static void main(String[] argv){
		ArrayList<Integer> obradjeni = new ArrayList<Integer>();
		try {
			Connection con = null;
			String url = "jdbc:db2://localhost:50001/vstud";
			con = DriverManager.getConnection(url,"student", "abcdef");


			Statement stmt = con.createStatement();
			String upit1 = "select predmet.id_predmeta, naziv, predmet.bodovi " +
					"						  from predmet join obavezan_predmet " +
					"						  on predmet.id_predmeta = obavezan_predmet.id_predmeta " +
					"						  where obavezan_predmet.id_smera = 201";
			ResultSet rs = stmt.executeQuery(upit1);
			String upit = "update predmet" +
					"	   set bodovi = bodovi + 1" +
					"	   where id_predmeta = ? ";

			PreparedStatement stmtUpd = con.prepareStatement(upit);

			while(rs.next()){
				try {
					System.out.println("ID: " + rs.getInt(1) + " NAZIV:" + rs.getString(2) + " BODOVI:" + rs.getInt(3));
					System.out.println("Da li zelis da promenis?");
					Scanner sc = new Scanner(System.in);
					String answer  = sc.next();
					if (answer.equalsIgnoreCase("da")){
						//treba provera da li smo vec obradili
						if (!obradjeni.contains(rs.getInt(1))){
							//mozemo da ga update
								stmtUpd.setInt(1, rs.getInt(1));
								try {
									int updated = stmtUpd.executeUpdate();
									System.out.println("Updateovano");
									con.commit();
									obradjeni.add(rs.getInt(1));

								} catch (SQLException e) {
									if (e.getErrorCode()==-913 || e.getErrorCode()==-911){
										rs.close();
										con.rollback();
										rs = stmt.executeQuery(upit1);
									}
								}
							}
					}

					} catch(SQLException e){
						con.rollback();
						rs = stmt.executeQuery(upit1);
					}
				}
			rs.close();
			stmt.close();
			stmtUpd.close();
			con.close();
		} catch (Exception e) {
			e.printStackTrace();
		}

	}
}