包 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));

}

}

}