소스 검색

修改sql

wanggangtao 5 년 전
부모
커밋
f971491e10
3개의 변경된 파일7개의 추가작업 그리고 18개의 파일을 삭제
  1. 1 1
      lib/day_k_base.class.php
  2. 1 1
      lib/sina.class.php
  3. 5 16
      lib/table/table_day_k_base.class.php

+ 1 - 1
lib/day_k_base.class.php

@@ -18,7 +18,7 @@ class Day_k_base {
     static public function add($attrs)
     {
         if (empty($attrs)) throw new Exception('参数不能为空', 102);
-        $Table_day_k_base = new Table_day_k_base('202011');
+        $Table_day_k_base = new Table_day_k_base('202009');
         $id = $Table_day_k_base->add($attrs);
         return $id;
     }

+ 1 - 1
lib/sina.class.php

@@ -34,7 +34,7 @@ class sina
             $stock_code = "1".$code;
         }
         $url = "http://hq.sinajs.cn/list=".$stock_code;
-//        var_dump($url);
+
         $curlHandle = curl_init();
         curl_setopt( $curlHandle , CURLOPT_URL, $url );
         curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 );

+ 5 - 16
lib/table/table_day_k_base.class.php

@@ -53,7 +53,7 @@ class Table_day_k_base extends Table {
         parent::__construct();
         $this->table_name .= $date;//表名不代前缀
         $this->table_fullname .= $date;//表名代前缀
-        //$this ->createBaseTable();
+        $this ->createBaseTable();
     }
 
     /****
@@ -61,13 +61,10 @@ class Table_day_k_base extends Table {
      * 王刚涛
      */
      public function createBaseTable(){
-//         $mypdo = new MyPdo();//这里框架中的pdo不能用
-//         $this->pdo=$mypdo;
-         $sql = " CREATE TABLE IF NOT EXISTS `". $this->table_fullname."` as select * from boniu_day_k_base where 0 ";
-//         var_dump($sql);
-//         $this->pdo->execSql($sql);
-
-   }
+         global $mypdo;
+         $sql = " CREATE TABLE IF NOT EXISTS `". $this->table_fullname."` LIKE  boniu_day_k_base";
+         $mypdo->pdo->exec($sql);
+     }
 
     /****
      * @param $attr
@@ -84,15 +81,7 @@ class Table_day_k_base extends Table {
              'day_k_amount'    => array('number', $attr['amount']),
              'day_k_value'    => array('number', $attr['value']),
         );
-//        var_dump($this->pdo);
-//        var_dump($this);
-
-//        $mypdo = new MyPdo();//这里框架中的pdo不能用
-//        $this->pdo=$mypdo;
-
-
         $msg=$this->pdo->sqlinsert($this->table_fullname, $param);
-
         return $msg;
     }