CronAction.class.php 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. <?php
  2. class CronAction extends Action {
  3. public function deleteWdRecords( ){
  4. $config = C('ORACLE_CONFIG');
  5. $host= $config['host'];
  6. $port= $config['port'];
  7. $instance_name= $config['instance_name'];
  8. $username= $config['username'];
  9. $password= $config['password'];
  10. /*
  11. $host= '192.168.100.23';
  12. $port= '1521';
  13. $instance_name= 'helowin';
  14. $username= 'DSSC3';
  15. $password= 'Rliandssc3';
  16. */
  17. $conn = oci_connect($username, $password, $host.':'.$port.'/'. $instance_name,'AL32UTF8');
  18. if (!$conn) {
  19. $e = oci_error();
  20. trigger_error(htmlentities($e['message'], ENT_QUOTES), E_USER_ERROR);
  21. }
  22. $min_id=0;
  23. $max_id=0;
  24. $query_sql='select ID from DSSC2.W_DW_RF_RECORD where rownum = 1 order by ID Asc ';
  25. $stid = oci_parse($conn, $query_sql);
  26. oci_define_by_name($stid, 'ID', $min_id);
  27. oci_execute($stid);
  28. oci_fetch($stid);
  29. $max_id=0;
  30. $query_sql='select ID from DSSC2.W_DW_RF_RECORD where rownum = 1 order by ID Desc ';
  31. $stid = oci_parse($conn, $query_sql);
  32. oci_define_by_name($stid, 'ID', $max_id);
  33. oci_execute($stid);
  34. oci_fetch($stid);
  35. $delete_id=$max_id-800000000;
  36. while($min_id<=$delete_id){
  37. $del_sql='DELETE FROM DSSC2.W_DW_RF_RECORD WHERE ID = 6468026663';
  38. $stid = oci_parse($conn, $del_sql);
  39. $r = oci_execute($stid);
  40. $min_id++;
  41. }
  42. }
  43. }