Files
erp-site/application/models/mysql_model.php
2026-04-19 01:39:41 +08:00

115 lines
3.0 KiB
PHP
Executable File

<?php
defined('BASEPATH') OR exit('No direct script access allowed');
class Mysql_model extends CI_Model {
public function __construct(){
parent::__construct();
}
public function query($sql,$type=1) {
$query = $this->db->query($sql);
switch ($type) {
case 1:
$result = $query->row_array();break;
case 2:
$result = $query->result_array();break;
case 3:
$result = $query->num_rows();break;
}
return $result;
}
public function get_results($table,$where='',$order='',$limit1=0,$limit2=0,$select='*') {
$this->db->select($select);
$this->db->from($this->db->dbprefix($table));
if ($where) {
$this->db->where($where);
}
if ($order) {
$this->db->order_by($order);
}
if ($limit2>0) {
$this->db->limit($limit2, $limit1);
}
$query = $this->db->get();
return $query->result_array();
}
public function get_rows($table,$where=array(1=>1),$select='*') {
$query = $this->db->select($select)
->from($this->db->dbprefix($table))
->where($where)
->get();
return $query->row_array();
}
public function get_row($table,$where=array(1=>1),$select) {
$query = $this->db->select($select)
->from($this->db->dbprefix($table))
->where($where)
->get();
$result = $query->row_array();
return $result[$select];
}
public function get_count($table,$where=array(1=>1),$select='*') {
return $this->db->select($select)
->from($this->db->dbprefix($table))
->where($where)
->count_all_results();
}
public function insert($table,$data){
$table = $this->db->dbprefix($table);
if (isset($data[0]) && is_array($data[0])) {
$this->db->insert_batch($table, $data);
} else {
$this->db->insert($table, $data);
}
$this->db->cache_delete_all();
return $this->db->insert_id();
}
public function update($table,$data,$where='') {
$table = $this->db->dbprefix($table);
if (isset($data[0]) && is_array($data[0])) {
$this->db->update_batch($table,$data,$where);
if ($this->db->affected_rows()) {
$result = true;
}
} else {
if (is_array($data)&&count($data)>0) {
if ($where) {
$this->db->where($where);
}
$result = $this->db->update($table, $data);
} else {
if (!is_array($data)) {
$result = $this->db->query('UPDATE '.$table.' SET '.$data .($where ? ' WHERE '.$where : ''));
}
}
}
if (isset($result)) {
$this->db->cache_delete_all();
return $result;
}
return false;
}
public function delete($table,$where='') {
$table = $this->db->dbprefix($table);
if ($where) {
$this->db->where($where);
}
$this->db->delete($table);
if ($this->db->affected_rows()) {
$this->db->cache_delete_all();
return true;
}
return false;
}
}