java 操作MySQL，查询，插入，更新和删除操作

一、具体Java sql操作代码：

package operationmysql;

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

public class OperationMethods {
//插入方法
public void InsertMethods(Connection conn,String mysql){
mysql="insert into javaSql (id,rowkey,webcon) values (?,?,?)";
PreparedStatement pst=null;
try {
pst = conn.prepareStatement(mysql);
pst.setInt(1,2);
pst.setString(2,"beijing");
pst.setString(3,"chaoyang");
pst.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
pst.close();
conn.close();
System.out.println("插入成功...");
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println("插失败...");
e.printStackTrace();
}
}
}

//更新方法
public void UpdateMethod(Connection conn,String mysql){
PreparedStatement pst=null;
//特别注意：在执行更新操作时，一定要指明更新的条件，不然会把表中所有的数据都进行更新，带来的后果就非常严重了。
mysql="update javaSql set id=?,rowkey=?,webcon=? where id=?";
try {
pst = conn.prepareStatement(mysql);
//注意，设置的序号从1开始，1位置的值对应第一个？，2对应第二个？，依次类推进行对？位置进行赋值
pst.setInt(1,3);
pst.setString(2,"anhui");
pst.setString(3,"fuyang");
pst.setInt(4,2);
pst.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
pst.close();
conn.close();
System.out.println("更新成功...");
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println("更新失败...");
e.printStackTrace();
}
}
}

//查询方法
public void QueryMethds(Connection conn,String mysql){
ResultSet rs=null;
mysql="select * from javaSql where id=?";
try {
Statement stmt = conn.createStatement();
rs = stmt.executeQuery(mysql);
while (rs.next()){
System.out.print(rs.getInt(1) + "\t");
System.out.print(rs.getString(2) + "\t");
System.out.print(rs.getString(3) + "\t");
System.out.println();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
rs.close();
conn.close();
System.out.println("查询结束...");
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println("查询失败...");
e.printStackTrace();
}

}
}

//删除方法
public void DeleteMethods(Connection conn,String mysql){
PreparedStatement pst=null;
//特别注意：删除的时候，一定严格指定删除条件，因为只要满足条件的数据，都会被删除掉，一旦删除，带来的后果很严重
mysql="delete from javaSql where id=?";
try {
pst = conn.prepareStatement(mysql);
pst = conn.prepareStatement(mysql);
pst.setInt(1,3);
pst.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
pst.close();
conn.close();
System.out.println("删除成功...");
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println("删除失败...");
e.printStackTrace();
}
}
}
}

二、测试代码：

package operationmysql;

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

public class TestMySQLOperation {
public static void main(String[] args) throws Exception {
//回去驱动
Class.forName("com.mysql.jdbc.Driver");
//设置jdbc链接
String url="jdbc:mysql://192.168.3.108:3306/test";
Connection connection = DriverManager.getConnection(url,"root","mysql");
String mysql=null;
OperationMethods om = new OperationMethods();
// om.InsertMethods(connection, mysql);
om.UpdateMethod(connection, mysql);
// om.DeleteMethods(connection, mysql);

}

}