包 cn.gtmc.schedule.app; 导入 cn.gtmc.schedule.domain.Employee; import java.sql。 * ; 导入 java.util.ArrayList; 导入 java.util.List;
公共 类 ScheduleApp {
公共 连接getCon(){
// 数据库连接名称
字符串username =" root" ;
// 数据库连接密码
字符串密码=" root" ;
字符串驱动程序 =" com.mysql.jdbc.Driver" ;
// 其中test是数据库名称
字符串url =" jdbc:mysql://node1:3306/test" ;
连接conn = null ;
试试
Class.forName(驱动程序);
conn = (连接)DriverManager.getConnection(URL,用户名,密码);
} catch (异常e){
e.printStackTrace();
}
返回 conn;
}
public void addData(员工员工){
字符串sql ="插入copyEmployee(id,名称,电子邮件,性别)值(?,?,?,?)"。;
java.sql.PreparedStatement ptmt = null ;
试试
ptmt = getCon()。 prepareStatement(sql);
ptmt.setString( 1 ,employee.getId());
ptmt.setString( 2 ,employee.getLastName());
ptmt.setString( 3 ,employee.getEmail());
ptmt.setString( 4 ,employee.getGender());
ptmt.execute(); // 执行给定的SQL语句,该语句可能返回多个结果
} catch (SQLException e){
e.printStackTrace();
}
}
public列表\ lt;员工getSelect(){
字符串sql ="从员工中选择*" ;
连接conn = getCon();
PreparedStatement pst = null ;
// 定义一个列表以接受数据库查询的内容
列出\ lt;员工list = new ArrayList \ lt;员工();
试试
pst = (PreparedStatement)conn.prepareStatement(sql);
ResultSet rs = pst.executeQuery();
而 (rs.next()){
雇员雇员 = 新 Employee();
// 将查询的内容添加到列表中
字符串ID = rs.getString(" id" );
字符串lastName = rs.getString(" name" );
字符串电子邮件 = rs.getString("电子邮件" );
字符串性别 = rs.getString("性别" );
employee.setLastName(lastName.substring( 2,4)); // 此边进行现场处理
employee.setId(id);
employee.setEmail(电子邮件);
employee.setGender(性别);
addData(员工);
}
} catch (异常e){
}
返回 list;
}
public 静态 void main(字符串[] args){
ScheduleApp应用 = 新 ScheduleApp();
列表 \ lt;员工list = app.getSelect();
for(int i = 0; i \ lt;列表。 size(); i ++ ){
System.out.println(list.get(i));
}
}
}