Revision 629
Added by berkley over 23 years ago
| ReplicationHandler.java | ||
|---|---|---|
| 446 | 446 |
PreparedStatement pstmt; |
| 447 | 447 |
try |
| 448 | 448 |
{
|
| 449 |
pstmt = conn.prepareStatement("select server, last_checked from " +
|
|
| 450 |
"xml_replication"); |
|
| 449 |
pstmt = conn.prepareStatement("select server, last_checked, replicate " +
|
|
| 450 |
"from xml_replication");
|
|
| 451 | 451 |
pstmt.execute(); |
| 452 | 452 |
ResultSet rs = pstmt.getResultSet(); |
| 453 | 453 |
boolean tableHasRows = rs.next(); |
| 454 | 454 |
while(tableHasRows) |
| 455 | 455 |
{
|
| 456 |
String server = rs.getString(1); |
|
| 457 |
String last_checked = rs.getString(2); |
|
| 458 |
if(!server.equals("localhost"))
|
|
| 459 |
{
|
|
| 460 |
sl.put(server, last_checked); |
|
| 456 |
if(rs.getInt(3) == 1) |
|
| 457 |
{//only put the server in the list if the replicate flag is true
|
|
| 458 |
String server = rs.getString(1); |
|
| 459 |
String last_checked = rs.getString(2); |
|
| 460 |
if(!server.equals("localhost"))
|
|
| 461 |
{
|
|
| 462 |
sl.put(server, last_checked); |
|
| 463 |
} |
|
| 461 | 464 |
} |
| 462 |
tableHasRows = rs.next(); |
|
| 465 |
tableHasRows = rs.next();
|
|
| 463 | 466 |
} |
| 464 | 467 |
} |
| 465 | 468 |
catch(Exception e) |
Also available in: Unified diff
added support for one way replication