您的位置:首页 > 数据库

关于数据库增删改查练习

2015-10-09 19:30 405 查看
package q;

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

public class Jdbc {

private static Connection con;

public static void main(String[] args) {

try {

// 1.加载驱动
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
// 2.建立连接
con = DriverManager.getConnection(
"jdbc:sqlserver://127.0.0.1:1433;databasename=HpExp",
"sa", "123456");

// 3.创建声明,进行数据库查询
PreparedStatement ps = con
.prepareStatement("select id,name,saraly from exp");
// 4.将查询结果存储到rs中
ResultSet rs = ps.executeQuery();
// 5.遍历结果集rs,打印输出
while (rs.next()) {
int id = rs.getInt(1);
String name = rs.getString(2);
String saraly = rs.getString(3);
System.out.println("id:" + id + "\tname:" + name + "\tsaraly:"
+ saraly);
}

System.out.println("---------------------------------------------");

// 6.创建声明,进行数据库修改
PreparedStatement ps1 = con
.prepareStatement("update exp set saraly='3000'");
// 7.将结果存储到rs1中
int rs1 = ps1.executeUpdate();
if (rs1 != 0) {
// 8.创建声明,进行数据库查询
ResultSet rs11 = ps.executeQuery();
// 9.遍历结果集rs11,打印输出
while (rs11.next()) {
int id = rs11.getInt(1);
String name = rs11.getString(2);
String saraly = rs11.getString(3);
System.out.println("id:" + id + "\tname:" + name
+ "\tsaraly:" + saraly);
}

}

System.out.println("---------------------------------------");
// 10.创建声明,进行数据库增加
PreparedStatement ps2 = con
.prepareStatement("insert exp (id,name,saraly) values(6,'888',5)");
// 7.将结果存储到rs2中
int rs2 = ps2.executeUpdate();
if (rs2 != 0) {
// 8.创建声明,进行数据库查询
ResultSet rs22 = ps.executeQuery();
// 9.遍历结果集rs11,打印输出
while (rs22.next()) {
int id = rs22.getInt(1);
String name = rs22.getString(2);
String saraly = rs22.getString(3);
System.out.println("id:" + id + "\tname:" + name
+ "\tsaraly:" + saraly );
}

}

System.out.println("---------------------------------------");
// 10.创建声明,进行数据库删除
PreparedStatement ps3 = con
.prepareStatement("delete exp where id=6");
// 7.将结果存储到rs3中
int rs3 = ps3.executeUpdate();
if (rs3 != 0) {
// 8.创建声明,进行数据库查询
ResultSet rs33 = ps.executeQuery();
// 9.遍历结果集rs11,打印输出
while (rs33.next()) {
int id = rs33.getInt(1);
String name = rs33.getString(2);
String saraly = rs33.getString(3);
System.out.println("id:" + id + "\tname:" + name
+ "\tsaraly:" + saraly );
}

}

rs.close();
ps.close();
con.close();

} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}

}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: