getmovies

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package bigdatamangementcs1;

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 *
 * @author cyl1
 */
public class getmovies {
    public getmovies() {
        try {
                        //connects to database using jdbc driver
			Class.forName("com.mysql.jdbc.Driver").newInstance();
			Connection conn = DriverManager.getConnection("jdbc:mysql://mysql-server-1.macs.hw.ac.uk/movielens?user=cyl1&password=abccyl1354");
			Statement st = conn.createStatement();

                        //query for getting data from mysql
			String query = "SELECT * FROM movies";
                        ResultSet rs = st.executeQuery(query);

                        //string for data for json
                        String json = "";

                        //creating json file
                        File file = new File("movies.json");

                        //creates new file if file doesnt exists
                        if (!file.exists()){
                            file.createNewFile();
                        }

                        //Writing code for json
                        FileWriter fw = new FileWriter(file.getAbsoluteFile());
                        BufferedWriter bw = new BufferedWriter(fw);
                        String movies="";
                        //loop
                        while(rs.next()){
                            int id = rs.getInt("id");
                            String title = rs.getString("title");
                            String rd = rs.getString("release_date");
                            String video = rs.getString("video");
                            String IMDBURL = rs.getString("IMDBURL");

                            //System.out.format("%s %s\n", id,genre);
                            json = "{\"_id\" :"+id+", "
                                    + "\"title\" :\""+title+"\", "
                                    +"\"release_date\" :\""+rd+"\", "
                                    +"\"video\" : \""+video+"\" , "
                                    +"\"IMDBURL\" : \""+IMDBURL+"\"}\n";
                            bw.write(json);

                        }
                        bw.close();
			st.close();
			conn.close();
                        System.out.println("movie.json saved");
		} catch (Exception e) {
			System.out.println("ERROR!! " +e);
                }
    }
}