包 cn.gtmc.schedule.app; 導(dǎo)入 cn.gtmc.schedule.domain.Employee; import java.sql。 * ; 導(dǎo)入 java.util.ArrayList; 導(dǎo)入 java.util.List;

公共 類 ScheduleApp {

公共 連接getCon(){

// 數(shù)據(jù)庫連接名稱

字符串username =" root" ;

// 數(shù)據(jù)庫連接密碼

字符串密碼=" root" ;

字符串驅(qū)動程序 =" com.mysql.jdbc.Driver" ;

// 其中test是數(shù)據(jù)庫名稱

字符串url =" jdbc:mysql://node1:3306/test" ;

連接conn = null ;

試試

Class.forName(驅(qū)動程序)；

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(); // 執(zhí)行給定的SQL語句，該語句可能返回多個(gè)結(jié)果

} catch (SQLException e){

e.printStackTrace();

}

}

public列表\ lt;員工getSelect(){

字符串sql ="從員工中選擇*" ;

連接conn = getCon();

PreparedStatement pst = null ;

// 定義一個(gè)列表以接受數(shù)據(jù)庫查詢的內(nèi)容

列出\ lt;員工list = new ArrayList \ lt;員工();

試試

pst = (PreparedStatement)conn.prepareStatement(sql);

ResultSet rs = pst.executeQuery();

而 (rs.next()){

雇員雇員 = 新 Employee();

// 將查詢的內(nèi)容添加到列表中

字符串ID = rs.getString(" id" );

字符串lastName = rs.getString(" name" );

字符串電子郵件 = rs.getString("電子郵件" )；

字符串性別 = rs.getString("性別" )；

employee.setLastName(lastName.substring( 2,4)); // 此邊進(jìn)行現(xiàn)場處理

employee.setId(id);

employee.setEmail(電子郵件);

employee.setGender(性別)；

addData(員工)；

}

} catch (異常e){

}

返回 list;

}

public 靜態(tài) void main(字符串[] args){

ScheduleApp應(yīng)用 = 新 ScheduleApp();

列表 \ lt;員工list = app.getSelect();

for(int i = 0; i \ lt;列表。 size(); i ++ ){

System.out.println(list.get(i));

}

}

}

總結(jié)

以上是生活随笔為你收集整理的java实现两张表的数据同步,java实现mysql数据库从一张表插入数据到另一张表的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。