package mysqlTest;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
public class dbstart {
public static void main(String[] args)throws Exception {
// library - mysql
// connection
Connection conn = getMySqlConnection();
//insert
//insertUser(conn, "three", "pass", "michael", "aaa@aaa.com");
// read (select)
ResultSet rs = getUsers(conn);
while(rs.next()){
System.out.println(rs.getString(1) +" " + rs.getString(2) +" " + rs.getString(3));
}
// update
// delete
}
public static ResultSet getUsers(Connection conn) throws Exception{
return getResultSet(conn, "select * from users");
}
public static ResultSet getResultSet(Connection conn, String sql) throws Exception {
Class.forName("com.mysql.jdbc.Driver");
Statement stm = conn.createStatement(java.sql.ResultSet.CONCUR_READ_ONLY, java.sql.ResultSet.TYPE_FORWARD_ONLY);
return stm.executeQuery(sql);
}
public static void insertUser(Connection conn, String userid, String password, String name, String email) throws Exception{
PreparedStatement pst = conn.prepareStatement("Insert into users values(?,?,?,?)");
pst.setString(1, userid);
pst.setString(2, password);
pst.setString(3, name);
pst.setString(4, email);
pst.execute();
pst.close();
}
public static Connection getMySqlConnection() throws Exception {
Class.forName("com.mysql.jdbc.Driver");
return DriverManager.getConnection("jdbc:mysql://10.131.173.19/slipp_dev", "dbuser", "Password01");
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
public class dbstart {
public static void main(String[] args)throws Exception {
// library - mysql
// connection
Connection conn = getMySqlConnection();
//insert
//insertUser(conn, "three", "pass", "michael", "aaa@aaa.com");
// read (select)
ResultSet rs = getUsers(conn);
while(rs.next()){
System.out.println(rs.getString(1) +" " + rs.getString(2) +" " + rs.getString(3));
}
// update
// delete
}
public static ResultSet getUsers(Connection conn) throws Exception{
return getResultSet(conn, "select * from users");
}
public static ResultSet getResultSet(Connection conn, String sql) throws Exception {
Class.forName("com.mysql.jdbc.Driver");
Statement stm = conn.createStatement(java.sql.ResultSet.CONCUR_READ_ONLY, java.sql.ResultSet.TYPE_FORWARD_ONLY);
return stm.executeQuery(sql);
}
public static void insertUser(Connection conn, String userid, String password, String name, String email) throws Exception{
PreparedStatement pst = conn.prepareStatement("Insert into users values(?,?,?,?)");
pst.setString(1, userid);
pst.setString(2, password);
pst.setString(3, name);
pst.setString(4, email);
pst.execute();
pst.close();
}
public static Connection getMySqlConnection() throws Exception {
Class.forName("com.mysql.jdbc.Driver");
return DriverManager.getConnection("jdbc:mysql://10.131.173.19/slipp_dev", "dbuser", "Password01");
}
}
Comments
Post a Comment