tpaaVu6h

1private void crearBD() {
2		try {
3
4			String base = "CREATE SCHEMA if not exists diagnostico;";
5			String source = "CREATE TABLE diagnostico."
6					+ "source (source_id INT NULL,"
7					+ " name VARCHAR(255) NULL,PRIMARY KEY (source_id));";
8
9			if (conn == null || conn.isClosed())
10				this.conectar();
11			
12			Statement st = conn.createStatement();
13			// Comprobamos si existe la base de datos
14			ResultSet rs = st.executeQuery("SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = 'diagnostico'");
15			// Si no existe la creamos
16			if(rs == null || !rs.next()){
17				st.executeUpdate(base);
18			}
19			else {
20				//Preguntamos si se quiere borrar la base
21				Scanner sc = new Scanner(System.in);
22				System.out.println("¿Quieres borrar la base de datos? S/N");
23				String respuesta = sc.next();
24				if (respuesta.equals("S")){
25					st.executeUpdate("DROP DATABASE diagnostico;");
26					st.executeUpdate("CREATE SCHEMA diagnostico;");
27				}
28			}
29		}
30		catch (Exception e) {
31			System.out.println(e);
32		}
33	}