Pre-requisites:
1)mySQL
2)A sample table with data in it
3)com.mysql.jdbc_5.1.5.jar
--------------------------------------------------------------------------------------------------------------------------
package DatabaseConnectivity;
import java.sql.*;
public class mySqlJdbcDemo
{
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost";
// Database credentials
static final String USER = "root";
static final String PASS = "password";
public static void main(String[] args) throws Exception
{
//STEP 1: Register JDBC driver
Class.forName(JDBC_DRIVER);
//STEP 2: Open a connection
Connection conn = DriverManager.getConnection(DB_URL,USER,PASS);
System.out.println("Connected");
System.out.println("+++++++++++");
//STEP 3:Create statement Object
Statement stmt=conn.createStatement();
//STEP 4:Execute the query
ResultSet rs=stmt.executeQuery("SELECT * FROM test.employee");
while(rs.next())
{
System.out.println(rs.getString(2)); // 2 represents column # 2
}
conn.close();
System.out.println("++++++++++++");
System.out.println("connection closed");
}
}
Output:
Connection established
++++++++++++
Harry
Jack
+++++++++++++
Connection closed
1)mySQL
2)A sample table with data in it
3)com.mysql.jdbc_5.1.5.jar
--------------------------------------------------------------------------------------------------------------------------
package DatabaseConnectivity;
import java.sql.*;
public class mySqlJdbcDemo
{
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost";
// Database credentials
static final String USER = "root";
static final String PASS = "password";
public static void main(String[] args) throws Exception
{
//STEP 1: Register JDBC driver
Class.forName(JDBC_DRIVER);
//STEP 2: Open a connection
Connection conn = DriverManager.getConnection(DB_URL,USER,PASS);
System.out.println("Connected");
System.out.println("+++++++++++");
//STEP 3:Create statement Object
Statement stmt=conn.createStatement();
//STEP 4:Execute the query
ResultSet rs=stmt.executeQuery("SELECT * FROM test.employee");
while(rs.next())
{
System.out.println(rs.getString(2)); // 2 represents column # 2
}
conn.close();
System.out.println("++++++++++++");
System.out.println("connection closed");
}
}
Output:
Connection established
++++++++++++
Harry
Jack
+++++++++++++
Connection closed
No comments:
Post a Comment