FilesExpand file tree

 v2

/

Ezsql_codeigniter.php

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

161 lines (124 loc) · 4 KB

 v2

/

Ezsql_codeigniter.php

Copy path

Top

File metadata and controls

• Code
• Blame

161 lines (124 loc) · 4 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

<?php

/**********************************************************************

* Author: Justin Vincent (jv@jvmultimedia.com)

* Web...: http://jvmultimedia.com

* Name..: ezSQL_codeigniter

* Desc..: codeigniter component (part of ezSQL databse abstraction library)

*

*/

if ( ! defined('BASEPATH')) exit('No direct script access allowed');

if ( ! class_exists ('ezSQLcore') ) die('<b>Fatal Error:</b> ezSQL requires ezSQLcore (application/helpers/ez_sql_core_helper.php) to be included/loaded before it can be used');

class ezSQL_codeigniter extends ezSQLcore

{

var $debug = true;

var $rows_affected = false;

function __construct()

{

global $db;

$db = $this;

$this->CI =& get_instance();

}

function query($query)

{

// Initialise return

$return_val = 0;

// Flush cached values..

$this->flush();

// For reg expressions

$query = trim($query);

// Log how the function was called

$this->func_call = "\$db->query(\"$query\")";

// Keep track of the last query for debug..

$this->last_query = $query;

// Count how many queries there have been

$this->count(true, true);

// Start timer

$this->timer_start($this->num_queries);

// Use core file cache function

if ( $cache = $this->get_cache($query) )

{

// Keep tack of how long all queries have taken

$this->timer_update_global($this->num_queries);

// Trace all queries

if ( $this->use_trace_log )

{

$this->trace_log[] = $this->debug(false);

}

return $cache;

}

// Perform the query via CI database system

$ci_query = $this->CI->db->query($query);

// If there is an error then take note of it..

if ( $str = $this->CI->db->_error_message() )

{

$this->register_error($str);

$this->show_errors ? trigger_error($str,E_USER_WARNING) : null;

// If debug ALL queries

$this->trace || $this->debug_all ? $this->debug() : null ;

return false;

}

// Query was write (insert/delete/update etc.) query?

if ( preg_match("/^(insert|delete|update|replace|truncate|drop|create|alter)\s+/i",$query) )

{

$is_insert = true;

$this->rows_affected = $this->CI->db->affected_rows();

// Take note of the insert_id

if ( preg_match("/^(insert|replace)\s+/i",$query) )

{

$this->insert_id = $this->CI->db->insert_id();

}

// Return number fo rows affected

$return_val = $this->rows_affected;

}

// Query was a select

else

{

$is_insert = false;

// Store Query Results

$num_rows=0;

if ( $ci_query->num_rows() )

{

foreach ($ci_query->result() as $row)

{

// Take note of column info

if ( $num_rows == 0 )

{

$i=0;

foreach ( get_object_vars($row) as $k => $v )

{

$this->col_info[$i] = new Stdclass();

$this->col_info[$i]->name = $k;

$this->col_info[$i]->max_length = $k;

$this->col_info[$i]->type = '';

$i++;

}

}

// Store relults as an objects within main array

$this->last_result[$num_rows] = $row;

$num_rows++;

}

}

// Log number of rows the query returned

$return_val = $this->num_rows = $num_rows;

}

// disk caching of queries

$this->store_cache($query,$is_insert);

// If debug ALL queries

$this->trace || $this->debug_all ? $this->debug() : null ;

// Keep tack of how long all queries have taken

$this->timer_update_global($this->num_queries);

// Trace all queries

if ( $this->use_trace_log )

{

$this->trace_log[] = $this->debug(false);

}

return $return_val;

}

/**********************************************************************

* Format a sql string correctly for safe insert

*/

function escape($str, $like = FALSE)

{

return $this->CI->db->escape_str(stripslashes($str), $like = FALSE);

}

}