数据库json字段拆分成新字段

function convert_company_info($field) {
$select_field = $field.'_data';
$sql = "SELECT * FROM company_year_info WHERE ".$select_field." != ''";
$query = $this->db->query($sql);
if ($query->num_rows() > 0){
$result = $query->result_array();
$insert_param = array();
foreach ($result as $key => $value) {
$dataArr = json_decode($value[$select_field]);
$temp_param = array();
$temp_param['id'] = $value['id'];
foreach ($dataArr as $dataKey => $dataValue) {
$insert_key = $field."_".$dataKey;
$temp_param[$insert_key] = $dataValue;
}
$insert_param[] = $temp_param;
}
$this->db->update_batch('company_year_info',$insert_param,'id');
if($this->db->affected_rows()){
echo $this->db->affected_rows();
}
else{
echo "failed";
}
}
else{
return null;
}
}