java与MySql连接的增删查改

package com.tongking;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;

public class TestForMySQL {

/**
* @param args
* @throws ClassNotFoundException
* @throws SQLException
*/
public static void main(String[] args) throws ClassNotFoundException,
SQLException {
delete("4000");
findAll();
}

public static void findAll() throws ClassNotFoundException, SQLException {
// 1.加载驱动程序。
Class.forName("org.gjt.mm.mysql.Driver");

// 2.建立连接
String url = "jdbc:mysql://localhost/j2ee";
Connection conn = DriverManager.getConnection(url, "root", "root");

// 3.获得语句对象
Statement stmt = conn.createStatement();

// 4.执行SQL
ResultSet rs = stmt.executeQuery("select s_name,s_no from student");
while (rs.next()) {
// System.out.println("学生姓名：" + rs.getString(1));
System.out.println("学生姓名：" + rs.getString("s_name"));
System.out.println("学号：" + rs.getLong("s_no"));
}

// 5.释放资源
stmt.close();
conn.close();
}

public static void findByPk(String pk) throws ClassNotFoundException,
SQLException {
// 1.加载驱动程序。
Class.forName("org.gjt.mm.mysql.Driver");

// 2.建立连接
String url = "jdbc:mysql://localhost/j2ee";
Connection conn = DriverManager.getConnection(url, "root", "root");

// 3.获得语句对象
Statement stmt = conn.createStatement();

// 4.执行SQL
ResultSet rs = stmt
.executeQuery("select s_name,s_no from student where s_no = "
+ pk);
while (rs.next()) {
// System.out.println("学生姓名：" + rs.getString(1));
System.out.println("学生姓名：" + rs.getString("s_name"));
System.out.println("学号：" + rs.getLong("s_no"));
}

// 5.释放资源
stmt.close();
conn.close();
}

public static void insert() throws ClassNotFoundException, SQLException {
// 1.加载驱动程序。
Class.forName("org.gjt.mm.mysql.Driver");

// 2.建立连接
String url = "jdbc:mysql://localhost/j2ee";
Connection conn = DriverManager.getConnection(url, "root", "root");

// 3.获得语句对象
Statement stmt = conn.createStatement();

// 4.执行SQL
int count = stmt
.executeUpdate("insert into student (s_no,s_name,s_birthday,s_password) values (4000,'王五','1998-06-09','12345')");

// 5.释放资源
stmt.close();
conn.close();
}

public static void update(String sno) throws ClassNotFoundException,
SQLException {
// 1.加载驱动程序。
Class.forName("org.gjt.mm.mysql.Driver");

// 2.建立连接
String url = "jdbc:mysql://localhost/j2ee";
Connection conn = DriverManager.getConnection(url, "root", "root");

// 3.获得语句对象
Statement stmt = conn.createStatement();

// 4.执行SQL
int count = stmt
.executeUpdate("update student set s_name = '东流',s_birthday = '1998-06-02',s_password ='234' where s_no = "
+ sno);

// 5.释放资源
stmt.close();
conn.close();
}

public static void delete(String sno) throws ClassNotFoundException,
SQLException {
// 1.加载驱动程序。
Class.forName("org.gjt.mm.mysql.Driver");

// 2.建立连接
String url = "jdbc:mysql://localhost/j2ee";
Connection conn = DriverManager.getConnection(url, "root", "root");

// 3.获得语句对象
Statement stmt = conn.createStatement();

// 4.执行SQL
int count = stmt.executeUpdate("delete from student where s_no = "
+ sno);

// 5.释放资源
stmt.close();
conn.close();
}

}