Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Student.java
- ----------------------------
- public class Student {
- private int id;
- private String firstName;
- private String lastName;
- public Student(int id, String firstName, String lastName){
- this.id = id;
- this.firstName = firstName;
- this.lastName = lastName;
- }
- public Student(String firstName, String lastName){
- this(0,firstName,lastName);
- }
- public int getId() {
- return id;
- }
- public String getFirstName() {
- return firstName;
- }
- public String getLastName() {
- return lastName;
- }
- @Override
- public String toString() {
- return "Student{" +
- "id=" + id +
- ", firstName='" + firstName + '\'' +
- ", lastName='" + lastName + '\'' +
- '}';
- }
- }
- ----------------------------------------
- StudentsDBConn.java
- ----------------------------------------
- import java.sql.*;
- import java.util.ArrayList;
- import java.util.HashMap;
- import java.util.List;
- import java.util.Map;
- public class StudentsDBConn {
- static final private String TABLE_NAME = "studenttable";
- static final private String FIELD_ID = "id";
- static final private String FIELD_FIRSTNAME = "fname";
- static final private String FIELD_LASTNAME = "lname";
- private Connection conn;
- public StudentsDBConn() throws SQLException{
- String driverName = "com.mysql.jdbc.Driver";
- try {
- Class.forName(driverName);
- String url = "jdbc:mysql://eu-cdbr-sl-lhr-01.cleardb.net/ibmx_7aae882800d7265";
- String username = "b87b3718783680";
- String password = "d8e92cf6";
- Connection dbConn = DriverManager.getConnection(url,username,password);
- this.conn = dbConn;
- System.out.println("connected");
- }
- catch(ClassNotFoundException e){
- System.out.println(e);
- }
- }
- public void closeConnection() throws SQLException{
- this.conn.close();
- System.out.println("connection closed");
- }
- public void createTable() throws SQLException{
- String createString = "CREATE TABLE IF NOT EXISTS "+TABLE_NAME;
- createString += "(";
- createString += FIELD_ID+" int NOT NULL AUTO_INCREMENT PRIMARY KEY, ";
- createString += FIELD_FIRSTNAME+" varchar(255), ";
- createString += FIELD_LASTNAME+" varchar(255)";
- createString += ")";
- PreparedStatement createStatement = this.conn.prepareStatement(createString);
- createStatement.executeUpdate();
- System.out.println("table created");
- }
- public void insert(Student student) throws SQLException{
- String insertString = "INSERT INTO "+TABLE_NAME;
- insertString += "(";
- insertString += FIELD_FIRSTNAME+","+FIELD_LASTNAME;
- insertString += ")";
- insertString += " VALUES ";
- insertString += "(";
- insertString += "'"+student.getFirstName()+"','"+student.getLastName()+"'";
- insertString += ")";
- PreparedStatement insertStatement = this.conn.prepareStatement(insertString);
- insertStatement.executeUpdate();
- System.out.println("data inserted");
- }
- public List<Student> getAllData() throws SQLException{
- String selectString = "SELECT * FROM "+TABLE_NAME;
- PreparedStatement selectStatement = this.conn.prepareStatement(selectString);
- ResultSet response = selectStatement.executeQuery();
- Student rowStudent;
- List<Student> data = new ArrayList<>();
- while(response.next()){
- rowStudent = new Student(response.getInt(FIELD_ID),response.getString(FIELD_FIRSTNAME),response.getString(FIELD_LASTNAME));
- data.add(rowStudent);
- }
- System.out.println("data has been received");
- return data;
- }
- public void update(Student student) throws SQLException{
- String updateString = "UPDATE "+TABLE_NAME+" SET ";
- updateString += FIELD_FIRSTNAME+"='"+student.getFirstName()+"',";
- updateString += FIELD_LASTNAME+"='"+student.getLastName()+"' ";
- updateString += "WHERE "+FIELD_ID+"="+student.getId();
- PreparedStatement updateStatement = this.conn.prepareStatement(updateString);
- updateStatement.executeUpdate();
- System.out.println("data updated");
- }
- public void delete(int id) throws SQLException{
- String deleteString = "DELETE FROM "+TABLE_NAME+" WHERE "+FIELD_ID+"="+id;
- PreparedStatement deleteStatement = this.conn.prepareStatement(deleteString);
- deleteStatement.executeUpdate();
- System.out.println("data deleted");
- }
- public void dropTable() throws SQLException{
- String dropString = "DROP TABLE "+TABLE_NAME;
- PreparedStatement dropStatement = this.conn.prepareStatement(dropString);
- dropStatement.executeUpdate();
- System.out.println("table dropped");
- }
- }
- ---------------------------------------------------------
- Tester.java
- ---------------------------------------------------------
- import java.sql.SQLException;
- import java.util.List;
- import java.util.Map;
- public class Tester {
- public static void main(String[] args){
- try {
- StudentsDBConn conn = new StudentsDBConn();
- //conn.createTable();
- //conn.insert(new Student("lau","goldman"));
- //conn.update(new Student(1,"tzahi","mavriz"));
- //conn.delete(1);
- /*
- List<Student> data = conn.getAllData();
- for(Student row : data){
- System.out.println(row);
- }
- */
- //conn.dropTable();
- conn.closeConnection();
- }
- catch(SQLException e){
- System.out.println(e);
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement