JDBC project is added

Author: tanviavula

.metadata/.lock

@@ -0,0 +1,42 @@
+package com.lwl.jdbc;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+public class JdbcExample {
+
+	public static void main(String[] args) {
+		Connection conn = null;
+		Statement st = null;
+		ResultSet rs = null;
+		try {
+			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/batch_4", "lakshman", "lakshman");
+			st = conn.createStatement();
+			rs = st.executeQuery("select ename,job,sal from emp");
+			while(rs.next()) {
+				String name = rs.getString("ename");
+				String job = rs.getString("job");
+				float salary = rs.getFloat("sal");
+				System.out.printf("%s - %s - %f",name,job,salary);
+			}
+			
+		} catch (SQLException e) {
+			System.out.println("While getting employee details:"+e);
+			e.printStackTrace();
+		}finally {
+			try {
+				if(rs!=null)
+					rs.close();
+				if(st!=null)
+					st.close();
+				if(conn !=null)
+					conn.close();
+			}catch (Exception e) {
+				System.out.println("While closing resources: "+e);
+			}
+		}
+	}
+}

.metadata/.log

@@ -0,0 +1,46 @@
+package com.lwl.jdbc.test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.sql.Connection;
+import java.sql.Statement;
+
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+
+import com.lwl.jdbc.util.ConnectionUtil;
+
+public class JDBCCurdTest {
+	
+	@BeforeAll
+	public static void init() {
+		ConnectionUtil util = ConnectionUtil.util;
+		Connection con = null;
+		Statement st = null;
+
+		try {
+			System.out.println("Init is done");
+			con = util.getConnection();
+			st = con.createStatement();
+			String DROP_TABLE = "DROP TABLE IF EXISTS student";
+			String DROP_TABLE_ADDRESS = "DROP TABLE IF EXISTS address";
+			st.execute(DROP_TABLE);
+			st.execute(DROP_TABLE_ADDRESS);
+			String CREATE_STUDENT_TABLE = "create table student(sid int not null auto_increment,name varchar(100),email varchar(120),degree varchar(120),primary key(sid));";
+			String CREATE_STUDENT_TABLE = "create table student(sid int not null auto_increment,name varchar(100),email varchar(120),degree varchar(120),primary key(sid));";
+			st.execute(CREATE_STUDENT_TABLE);
+		} catch (Exception e) {
+			e.printStackTrace();
+		} finally {
+			util.close(st, con);
+		}
+	}
+
+	@Test
+	public void createTableStudent() {
+		
+
+	}
+}

.metadata/.mylyn/repositories.xml.zip

@@ -0,0 +1,87 @@
+package com.lwl.jdbc.test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.Statement;
+
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+
+import com.lwl.jdbc.util.ConnectionUtil;
+
+public class JDBCCurdTest {
+	
+	//@BeforeAll
+	public static void init() {
+		ConnectionUtil util = ConnectionUtil.util;
+		Connection con = null;
+		Statement st = null;
+
+		try {
+			System.out.println("Init is done");
+			con = util.getConnection();
+			st = con.createStatement();
+			String DROP_TABLE = "DROP TABLE IF EXISTS student";
+			String DROP_TABLE_ADDRESS = "DROP TABLE IF EXISTS address";
+			st.execute(DROP_TABLE);
+			st.execute(DROP_TABLE_ADDRESS);
+			String CREATE_STUDENT_TABLE = "create table student(sid int not null auto_increment,name varchar(100),email varchar(120),degree varchar(120),primary key(sid));";
+			String CREATE_ADDRESS_TABLE = "create table address(aid int not null auto_increment,city varchar(100),state varchar(120),sid int references student(sid),primary key(aid));";
+			st.execute(CREATE_STUDENT_TABLE);
+			st.execute(CREATE_ADDRESS_TABLE);
+		} catch (Exception e) {
+			e.printStackTrace();
+		} finally {
+			util.close(st, con);
+		}
+	}
+
+	//@Test
+	public void addStudentTest() {
+		
+		final String ADD_STUDENT = "insert into student(name,email,degree) values (?,?,?);";
+		ConnectionUtil util = ConnectionUtil.util;
+		Connection con = null;
+		PreparedStatement pst = null;
+		try {
+			con = util.getConnection();
+			pst = con.prepareStatement(ADD_STUDENT);
+			pst.setString(1,"Krish");
+			pst.setString(2, "krish@gmail.com");
+			pst.setString(3, "BE");
+			int count = pst.executeUpdate();
+			assertEquals(1, count);
+		}catch (Exception e) {	
+			e.printStackTrace();
+		}finally {
+			util.close(pst, con);
+		}
+		
+	}
+	
+	
+	@Test
+	public void deleteStudentTest() {
+		
+		String name = "'Krish' or 1 = 1";
+		final String DELETE_STUDENT = "delete from student where name="+name;
+		ConnectionUtil util = ConnectionUtil.util;
+		Connection con = null;
+		Statement st = null;
+		try {
+			con = util.getConnection();
+			st =con.createStatement();
+			int count = st.executeUpdate(DELETE_STUDENT);
+			assertEquals(1, count);
+		}catch (Exception e) {	
+			e.printStackTrace();
+		}finally {
+			util.close(st, con);
+		}
+		
+	}
+}

.metadata/.plugins/org.eclipse.core.resources/.history/12/002a4c9234a9001a1e108810345da353

@@ -0,0 +1,51 @@
+package com.lwl.jdbc;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+public class JdbcExample {
+	
+	static{
+		try {
+			Class.forName("com.mysql.jdbc.Driver");
+		}catch (Exception e) {
+			System.out.println("While loading driver :"+e);
+		}
+	}
+	
+	public static void main(String[] args) {
+		Connection conn = null;
+		Statement st = null;
+		ResultSet rs = null;
+		try {
+		
+			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/batch_4", "lakshman", "lakshman");
+			st = conn.createStatement();
+			rs = st.executeQuery("select ename,job,sal from emp");
+			while(rs.next()) {
+				String name = rs.getString("ename");
+				String job = rs.getString("job");
+				float salary = rs.getFloat("sal");
+				System.out.printf("\n%s - %s - %.2f",name,job,salary);
+			}
+			
+		} catch (SQLException e) {
+			System.out.println("While getting employee details:"+e);
+			e.printStackTrace();
+		}finally {
+			try {
+				if(rs!=null)
+					rs.close();
+				if(st!=null)
+					st.close();
+				if(conn !=null)
+					conn.close();
+			}catch (Exception e) {
+				System.out.println("While closing resources: "+e);
+			}
+		}
+	}
+}

.metadata/.plugins/org.eclipse.core.resources/.history/12/40f9de1afaa9001a10049cf511c91f24

@@ -0,0 +1,100 @@
+package com.lwl.ems.dao;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.List;
+
+import com.lwl.ems.domain.Dept;
+import com.lwl.ems.domain.Employee;
+import com.lwl.ems.dto.SalStat;
+import com.lwl.ems.util.DbConnectionUtil;
+
+public class EmployeeDaoImpl implements EmployeeDao {
+
+	private static final String DEPT_SAL_SAT = "select count(*) as count,max(sal) as max,min(sal) as min,avg(sal) as avg  from emp where deptno = ?";
+
+	private DbConnectionUtil dbUtil = DbConnectionUtil.dbutil;
+
+	@Override
+	public List<Employee> getEmployeeByDept(int deptno) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public List<Employee> maxSalaryEmployees() {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public Dept getDeptWhichHasMaxNumberOfEmployee() {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public List<Employee> getEmployeesWithManagers() {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public SalStat getSalStatOfOrganization() {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public SalStat getSalStatOfDept(int deptno) {
+		Connection con = null;
+		PreparedStatement pst = null;
+		ResultSet rs = null;
+		SalStat salStat = null;
+		try {
+			con = dbUtil.getConnection();
+			pst = con.prepareStatement(DEPT_SAL_SAT);
+			pst.setInt(1, deptno);
+			rs = pst.executeQuery();
+			if (rs.next()) {
+				long count = rs.getLong("count");
+				float min = rs.getFloat("min");
+				float max = rs.getFloat("max");
+				float avg = rs.getFloat("avg");
+				salStat = SalStat.builder().min(min).max(max).avg(avg).count(count).build();
+			}
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}finally {
+			dbUtil.close(rs, pst, con);
+		}
+		return salStat;
+	}
+
+	@Override
+	public List<String> allManagerNames() {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public List<Employee> whoJoinDayIs(String dayName) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public int addEmployees(List<Employee> list) {
+		// TODO Auto-generated method stub
+		return 0;
+	}
+
+	@Override
+	public int addDepartements(List<Dept> list) {
+		// TODO Auto-generated method stub
+		return 0;
+	}
+
+}