A tumblelog CMS built on AJAX, PHP and MySQL.

mysql_connection.class.php 9.0KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295
  1. <?php
  2. if(!defined('entry') || !entry) die('Not a valid page');
  3. /**
  4. * version 0.0.1
  5. *
  6. * Clase Conexion_Mysql
  7. *
  8. * @name Manejo de la conexion a la BD.
  9. * @version 0.0.1
  10. * @link http://www.pecesama.net/weblog/
  11. * @copyright MIT Licence
  12. * @author Pedro Santana [pecesama]
  13. */
  14. // constantes
  15. define('MYSQL_TYPES_NUMERIC', 'int real ');
  16. define('MYSQL_TYPES_DATE', 'datetime timestamp year date time ');
  17. define('MYSQL_TYPES_STRING', 'string blob ');
  18. class Conexion_Mysql {
  19. var $mbase_datos;
  20. var $mservidor;
  21. var $musuario;
  22. var $mclave;
  23. var $mid_conexion = 0; // Identificador de conexi�n
  24. var $mid_consulta = 0; // Identificador de consulta
  25. var $merror_numero = 0; // N�mero de error
  26. var $merror = ""; // Descripci�n del error.
  27. /** Al crear una instancia de clase, se ejecutara esta funcion */
  28. function Conexion_Mysql($bd="", $host="localhost", $user="", $pass="") {
  29. $this->mbase_datos = $bd;
  30. $this->mservidor = $host;
  31. $this->musuario = $user;
  32. $this->mclave = $pass;
  33. if (!$this->conectar()) {
  34. $mensaje = "
  35. <h3 class=\"important\">Error establishing a database connection</h3>
  36. <p>This either means that the username and password information in your <code>config.php</code> file is incorrect or we can't contact the database server at localhost. This could mean your host's database server is down.</p>
  37. <ul>
  38. <li>Are you sure you have the correct username and password?</li>
  39. <li>Are you sure that you have typed the correct hostname?</li>
  40. <li>Are you sure that the database server is running?</li>
  41. </ul>";
  42. die($mensaje);
  43. }
  44. }
  45. /** Conectar a la base de datos */
  46. function conectar() {
  47. // Conectamos al servidor
  48. $this->mid_conexion = @mysql_connect($this->mservidor, $this->musuario, $this->mclave);
  49. if (!$this->mid_conexion) {
  50. $this->merror = "No se logr� realizar la conexi�n.";
  51. return false;
  52. }
  53. //seleccionamos la base de datos
  54. if (!@mysql_select_db($this->mbase_datos, $this->mid_conexion)) {
  55. $this->merror = "No se puede abrir la base ".$this->mbase_datos ;
  56. return false;
  57. }
  58. return $this->mid_conexion; // Si todo salio bien regresa el id de la conexi�n
  59. }
  60. /** Para ejecutar consultas en la conexi�n abierta */
  61. function ejecutarConsulta($msql = "") {
  62. if ($msql == "") {
  63. $this->merror = "No introdujo la sentencia SQL";
  64. return false;
  65. }
  66. //ejecutamos la consulta
  67. $this->mid_consulta = mysql_query($msql, $this->mid_conexion);
  68. if (!$this->mid_consulta) {
  69. $this->merror_numero = mysql_errno();
  70. $this->merror = mysql_error()." error";
  71. return false;
  72. }
  73. return $this->mid_consulta; // Si todo salio bien regresa el id de la consulta
  74. }
  75. /**
  76. * Inserta un registro en la DB por cada llave->valor en un arreglo.
  77. * No se debe usar sentencias SQL con esta funcion.
  78. * Para usar sentencias SQL se debe utilizar ejecutarConsulta().
  79. *
  80. * @param mixed $tabla El nombre de la tabla en la BD.
  81. * @param array $datos Arreglo con los campos que se desean insertar $arreglo['campo'] = 'valor'.
  82. * @return string El ID del insert, verdadero si la tabla no tiene un campo auto_increment o false si ocurre un error.
  83. */
  84. function insertarDeFormulario($tabla, $datos) {
  85. if (empty($datos)) {
  86. $this->merror = "Debes de pasar un arreglo como parametro.";
  87. return false;
  88. }
  89. $cols = '(';
  90. $sqlValues = '(';
  91. foreach ($datos as $llave=>$valor) {
  92. $cols .= "$llave,";
  93. $tipo_col = $this->obtenerTipoCampo($tabla, $llave); // obtiene el tipo de campo
  94. if (!$tipo_col) return false; // error!
  95. // determina si se necesita poner comillas al valor.
  96. if (is_null($valor)) {
  97. $sqlValues .= "NULL,";
  98. }
  99. elseif (substr_count(MYSQL_TYPES_NUMERIC, "$tipo_col ")) {
  100. $sqlValues .= "$valor,";
  101. }
  102. elseif (substr_count(MYSQL_TYPES_DATE, "$tipo_col ")) {
  103. $valor = $this->formatearFecha($valor, $tipo_col); // formatea las fechas
  104. $sqlValues .= "'$valor',";
  105. }
  106. elseif (substr_count(MYSQL_TYPES_STRING, "$tipo_col ")) {
  107. $valor = $this->sql_escape($valor);
  108. $sqlValues .= "'$valor',";
  109. }
  110. }
  111. $cols = rtrim($cols, ',').')';
  112. $sqlValues = rtrim($sqlValues, ',').')';
  113. // inserta los valores en la DB
  114. $sql = "INSERT INTO $tabla $cols VALUES $sqlValues";
  115. return $this->ejecutarConsulta($sql);
  116. }
  117. /**
  118. * Modifica un registro en la DB por cada llave->valor en un arreglo.
  119. * No se debe usar sentencias SQL con esta funcion.
  120. * Para usar sentencias SQL se debe utilizar ejecutarConsulta().
  121. *
  122. * @param mixed $tabla El nombre de la tabla en la BD.
  123. * @param array $datos Arreglo con los campos que se desean insertar $arreglo['campo'] = 'valor'.
  124. * @param mixed $condicion Es basicame una clausula WHERE (sin el WHERE). Por ejemplo,
  125. * "columna=valor AND columna2='otro valor'" seria una condicion.
  126. * @return string El numero de registros afectados o verdadero si no necesitaba actualizarse el registro.
  127. * Falso si ocurrio algun error.
  128. */
  129. function modificarDeFormulario($tabla, $datos, $condicion="") {
  130. if (empty($datos)) {
  131. $this->merror = "Debes de pasar un arreglo como parametro.";
  132. return false;
  133. }
  134. $sql = "UPDATE $tabla SET";
  135. foreach ($datos as $llave=>$valor) {
  136. $sql .= " $llave=";
  137. $tipo_col = $this->obtenerTipoCampo($tabla, $llave); // obtiene el tipo de campo
  138. if (!$tipo_col) return false; // error!
  139. // determina si se necesita poner comillas al valor.
  140. if (is_null($valor)) {
  141. $sql .= "NULL,";
  142. }
  143. elseif (substr_count(MYSQL_TYPES_NUMERIC, "$tipo_col ")) {
  144. $sql .= "$valor,";
  145. }
  146. elseif (substr_count(MYSQL_TYPES_DATE, "$tipo_col ")) {
  147. $valor = $this->formatearFecha($valor, $tipo_col); /// formatea las fechas
  148. $sql .= "'$valor',";
  149. }
  150. elseif (substr_count(MYSQL_TYPES_STRING, "$tipo_col ")) {
  151. $valor = $this->sql_escape($valor);
  152. $sql .= "'$valor',";
  153. }
  154. }
  155. $sql = rtrim($sql, ','); // elimina la ultima coma
  156. if (!empty($condicion)) $sql .= " WHERE $condicion";
  157. // modifica los valores
  158. return $this->ejecutarConsulta($sql);
  159. }
  160. /**
  161. * Obtiene la informacion sobre un campo usando la funcion mysql_fetch_field.
  162. *
  163. * @param mixed $tabla El nombre de la tabla en la BD.
  164. * @param string $campo El campo del que se desea la informacion.
  165. * @return array Un arreglo con la informacion del campo o false si hay algun error.
  166. */
  167. function obtenerTipoCampo($tabla, $campo) {
  168. $r = mysql_query("SELECT $campo FROM $tabla");
  169. if (!$r) {
  170. $this->merror = mysql_error();
  171. return false;
  172. }
  173. $ret = mysql_field_type($r, 0);
  174. if (!$ret) {
  175. $this->merror = "No se puede obtener la informacion del campo ".$tabla.$campo.".";
  176. mysql_free_result($r);
  177. return false;
  178. }
  179. mysql_free_result($r);
  180. return $ret;
  181. }
  182. /**
  183. * Convierte una fecha en formato para DB.
  184. *
  185. * @param mixed $valor Se le puede pasar un valor timestamp como time() o un string como '04/14/2003 5:13 AM'.
  186. * @return date Fecha para insertar en la BD.
  187. */
  188. function formatearFecha($valor) {
  189. if(!eregi("^.{4}\-.{2}\-.{2}\ .{2}\:.{2}\:.{2}$",$valor)){
  190. if(eregi("^([0-9]+)$",$valor)){
  191. $valor = date("Y-m-d H:i:s",$valor);
  192. }else{
  193. // Estari� en el formato strtotime()
  194. $valor = date("Y-m-d H:i:s",strtotime($valor));
  195. }
  196. }
  197. return $valor;
  198. /* if (gettype($valor) == 'string') $valor = strtotime($valor);
  199. return date('Y-m-d H:i:s', $valor);
  200. */
  201. }
  202. /**
  203. * Obtiene el registro obtenido de una consulta.
  204. */
  205. function obtenerRegistro() {
  206. return mysql_fetch_assoc($this->mid_consulta);
  207. }
  208. /**
  209. * Devuelve el n�mero de campos de una consulta.
  210. */
  211. function contarCampos() {
  212. return mysql_num_fields($this->mid_consulta);
  213. }
  214. /**
  215. * Devuelve el n�mero de registros de una consulta.
  216. */
  217. function contarRegistros() {
  218. return @mysql_num_rows($this->mid_consulta);
  219. }
  220. /**
  221. * Devuelve el nombre de un campo de una consulta.
  222. */
  223. function obtenerNombreCampo($numero_campo) {
  224. return mysql_field_name($this->mid_consulta, $numero_campo);
  225. }
  226. /**
  227. * Muestra los datos de una consulta (para debug).
  228. */
  229. function verConsulta() {
  230. echo "<table border=1>\n";
  231. // mostramos los nombres de los campos
  232. for ($i = 0; $i < $this->contarCampos(); $i++) {
  233. echo "<td><b>".$this->obtenerNombreCampo($i)."</b></td>\n";
  234. }
  235. echo "</tr>\n";
  236. // mostrarmos los registros
  237. while ($row = mysql_fetch_row($this->mid_consulta)) {
  238. echo "<tr> \n";
  239. for ($i = 0; $i < $this->contarCampos(); $i++) {
  240. echo "<td>".$row[$i]."</td>\n";
  241. }
  242. echo "</tr>\n";
  243. }
  244. }
  245. /**
  246. * Cierra la conexion a la BD.
  247. */
  248. function cierraConexion() {
  249. mysql_free_result($this->mid_consulta);
  250. }
  251. function sql_escape($value) {
  252. if(get_magic_quotes_gpc()) {
  253. $value = stripslashes($value);
  254. }
  255. if( function_exists("mysql_real_escape_string")) {
  256. $value = mysql_real_escape_string($value);
  257. } else {
  258. $value = addslashes($value);
  259. }
  260. return $value;
  261. }
  262. } //fin de la Clase conexion_mysql
  263. ?>