你这个要操作数据库,通过jdbc的方式操作数据,实现增删改查。
public class TestMain {
// 表结构:
// id int
// login_acct varchar
// user_pswd varchar
// user_name varchar
// email varchar
// createTime varchar
@Before
public void Before () throws ClassNotFoundException {
Class.forName("com.mysql.jdbc.Driver");
}
private Connection Open() throws SQLException {
return DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/project_crowd", "root", "1234");
}
// 添加
@Test
public void save () {
try {
String sql = "insert into t_admin value(null, ?, ?, ?, ?, now())";
Connection open = Open();
PreparedStatement ps = open.prepareStatement(sql);
ps.setString(1, "tom");
ps.setString(2, "123456");
ps.setString(3, "塔姆");
ps.setString(4, "tom@qq.com");
ps.execute();
ps.close();
open.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// ID删除
@Test
public void del() {
try {
String sql = "delete from t_admin where id = ?";
Connection open = Open();
PreparedStatement ps = open.prepareStatement(sql);
ps.setInt(1, 2);
ps.execute();
ps.close();
open.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// 删除所有
@Test
public void delAll() {
try {
String sql = "delete from t_admin where id = ?";
Connection open = Open();
Statement st = open.createStatement();
int count = st.executeUpdate(sql);
st.close();
open.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// ID修改
@Test
public void edit() {
try {
String sql = "update t_admin set login_acct=?,user_pswd=?,user_name=?,email=? where id = ?";
Connection open = Open();
PreparedStatement ps = open.prepareStatement(sql);
ps.setString(1, "jack");
ps.setString(2, "jack.abc");
ps.setString(3, "杰克");
ps.setString(4, "jack@qq.com");
ps.setInt(5, 3);
ps.execute();
ps.close();
open.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// 查询
@Test
public void getAll() {
try {
String sql = "select * from t_admin";
Connection open = Open();
Statement st = open.createStatement();
ResultSet rs = st.executeQuery(sql);
while (rs.next()) {
int id = rs.getInt(1);
String acct = rs.getString(2);
String password = rs.getString(3);
String name = rs.getString(4);
String email = rs.getString(5);
String time = rs.getString(6);
System.out.println("编号:" + id + "\t登录账号:" + acct + "\t登录密码:" + password + "\t名称:" + name + "\t邮箱:" + email + "\t创建时间:" + time);
}
st.close();
open.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
删除所有最后使用!!!
您好,我是有问必答小助手,您的问题已经有小伙伴解答了,您看下是否解决,可以追评进行沟通哦~
如果有您比较满意的答案 / 帮您提供解决思路的答案,可以点击【采纳】按钮,给回答的小伙伴一些鼓励哦~~
ps: 问答会员年卡【8折】购 ,限时加赠IT实体书,即可 享受50次 有问必答服务,了解详情>>>https://t.csdnimg.cn/RW5m