Annotation of embedaddon/php/ext/mysqlnd/mysqlnd_loaddata.c, revision 1.1
1.1 ! misho 1: /*
! 2: +----------------------------------------------------------------------+
! 3: | PHP Version 5 |
! 4: +----------------------------------------------------------------------+
! 5: | Copyright (c) 2006-2012 The PHP Group |
! 6: +----------------------------------------------------------------------+
! 7: | This source file is subject to version 3.01 of the PHP license, |
! 8: | that is bundled with this package in the file LICENSE, and is |
! 9: | available through the world-wide-web at the following url: |
! 10: | http://www.php.net/license/3_01.txt |
! 11: | If you did not receive a copy of the PHP license and are unable to |
! 12: | obtain it through the world-wide-web, please send a note to |
! 13: | license@php.net so we can mail you a copy immediately. |
! 14: +----------------------------------------------------------------------+
! 15: | Authors: Georg Richter <georg@mysql.com> |
! 16: | Andrey Hristov <andrey@mysql.com> |
! 17: | Ulf Wendel <uwendel@mysql.com> |
! 18: +----------------------------------------------------------------------+
! 19: */
! 20:
! 21: #include "php.h"
! 22: #include "php_globals.h"
! 23: #include "mysqlnd.h"
! 24: #include "mysqlnd_wireprotocol.h"
! 25: #include "mysqlnd_priv.h"
! 26: #include "mysqlnd_debug.h"
! 27:
! 28:
! 29: #define ALLOC_CALLBACK_ARGS(a, b, c)\
! 30: if (c) {\
! 31: a = (zval ***)safe_emalloc(c, sizeof(zval **), 0);\
! 32: for (i = b; i < c; i++) {\
! 33: a[i] = mnd_emalloc(sizeof(zval *));\
! 34: MAKE_STD_ZVAL(*a[i]);\
! 35: }\
! 36: }
! 37:
! 38: #define FREE_CALLBACK_ARGS(a, b, c)\
! 39: if (a) {\
! 40: for (i = b; i < c; i++) {\
! 41: zval_ptr_dtor(a[i]);\
! 42: mnd_efree(a[i]);\
! 43: }\
! 44: mnd_efree(a);\
! 45: }
! 46:
! 47: /* {{{ mysqlnd_local_infile_init */
! 48: static
! 49: int mysqlnd_local_infile_init(void **ptr, char *filename, void **userdata TSRMLS_DC)
! 50: {
! 51: MYSQLND_INFILE_INFO *info;
! 52: php_stream_context *context = NULL;
! 53:
! 54: DBG_ENTER("mysqlnd_local_infile_init");
! 55:
! 56: info = ((MYSQLND_INFILE_INFO *)mnd_ecalloc(1, sizeof(MYSQLND_INFILE_INFO)));
! 57: if (!info) {
! 58: DBG_RETURN(1);
! 59: }
! 60:
! 61: *ptr = info;
! 62:
! 63: /* check open_basedir */
! 64: if (PG(open_basedir)) {
! 65: if (php_check_open_basedir_ex(filename, 0 TSRMLS_CC) == -1) {
! 66: strcpy(info->error_msg, "open_basedir restriction in effect. Unable to open file");
! 67: info->error_no = CR_UNKNOWN_ERROR;
! 68: DBG_RETURN(1);
! 69: }
! 70: }
! 71:
! 72: info->filename = filename;
! 73: info->fd = php_stream_open_wrapper_ex((char *)filename, "r", 0, NULL, context);
! 74:
! 75: if (info->fd == NULL) {
! 76: snprintf((char *)info->error_msg, sizeof(info->error_msg), "Can't find file '%-.64s'.", filename);
! 77: info->error_no = MYSQLND_EE_FILENOTFOUND;
! 78: DBG_RETURN(1);
! 79: }
! 80:
! 81: DBG_RETURN(0);
! 82: }
! 83: /* }}} */
! 84:
! 85:
! 86: /* {{{ mysqlnd_local_infile_read */
! 87: static
! 88: int mysqlnd_local_infile_read(void *ptr, char *buf, unsigned int buf_len TSRMLS_DC)
! 89: {
! 90: MYSQLND_INFILE_INFO *info = (MYSQLND_INFILE_INFO *)ptr;
! 91: int count;
! 92:
! 93: DBG_ENTER("mysqlnd_local_infile_read");
! 94:
! 95: count = (int)php_stream_read(info->fd, buf, buf_len);
! 96:
! 97: if (count < 0) {
! 98: strcpy(info->error_msg, "Error reading file");
! 99: info->error_no = CR_UNKNOWN_ERROR;
! 100: }
! 101:
! 102: DBG_RETURN(count);
! 103: }
! 104: /* }}} */
! 105:
! 106:
! 107: /* {{{ mysqlnd_local_infile_error */
! 108: static
! 109: int mysqlnd_local_infile_error(void *ptr, char *error_buf, unsigned int error_buf_len TSRMLS_DC)
! 110: {
! 111: MYSQLND_INFILE_INFO *info = (MYSQLND_INFILE_INFO *)ptr;
! 112:
! 113: DBG_ENTER("mysqlnd_local_infile_error");
! 114:
! 115: if (info) {
! 116: strlcpy(error_buf, info->error_msg, error_buf_len);
! 117: DBG_INF_FMT("have info, %d", info->error_no);
! 118: DBG_RETURN(info->error_no);
! 119: }
! 120:
! 121: strlcpy(error_buf, "Unknown error", error_buf_len);
! 122: DBG_INF_FMT("no info, %d", CR_UNKNOWN_ERROR);
! 123: DBG_RETURN(CR_UNKNOWN_ERROR);
! 124: }
! 125: /* }}} */
! 126:
! 127:
! 128: /* {{{ mysqlnd_local_infile_end */
! 129: static
! 130: void mysqlnd_local_infile_end(void *ptr TSRMLS_DC)
! 131: {
! 132: MYSQLND_INFILE_INFO *info = (MYSQLND_INFILE_INFO *)ptr;
! 133:
! 134: if (info) {
! 135: /* php_stream_close segfaults on NULL */
! 136: if (info->fd) {
! 137: php_stream_close(info->fd);
! 138: info->fd = NULL;
! 139: }
! 140: mnd_efree(info);
! 141: }
! 142: }
! 143: /* }}} */
! 144:
! 145:
! 146: /* {{{ mysqlnd_local_infile_default */
! 147: PHPAPI void mysqlnd_local_infile_default(MYSQLND *conn)
! 148: {
! 149: conn->infile.local_infile_init = mysqlnd_local_infile_init;
! 150: conn->infile.local_infile_read = mysqlnd_local_infile_read;
! 151: conn->infile.local_infile_error = mysqlnd_local_infile_error;
! 152: conn->infile.local_infile_end = mysqlnd_local_infile_end;
! 153: }
! 154: /* }}} */
! 155:
! 156: /* {{{ mysqlnd_set_local_infile_handler */
! 157: PHPAPI void mysqlnd_set_local_infile_handler(MYSQLND * const conn, const char * const funcname)
! 158: {
! 159: if (!conn->infile.callback) {
! 160: MAKE_STD_ZVAL(conn->infile.callback);
! 161: } else {
! 162: zval_dtor(conn->infile.callback);
! 163: }
! 164: ZVAL_STRING(conn->infile.callback, (char*) funcname, 1);
! 165: }
! 166: /* }}} */
! 167:
! 168:
! 169: static const char *lost_conn = "Lost connection to MySQL server during LOAD DATA of local file";
! 170:
! 171:
! 172: /* {{{ mysqlnd_handle_local_infile */
! 173: enum_func_status
! 174: mysqlnd_handle_local_infile(MYSQLND *conn, const char *filename, zend_bool *is_warning TSRMLS_DC)
! 175: {
! 176: char *buf = NULL;
! 177: char empty_packet[MYSQLND_HEADER_SIZE];
! 178: enum_func_status result = FAIL;
! 179: unsigned int buflen = 4096;
! 180: void *info = NULL;
! 181: int bufsize;
! 182: size_t ret;
! 183: MYSQLND_INFILE infile;
! 184:
! 185: DBG_ENTER("mysqlnd_handle_local_infile");
! 186:
! 187: if (!(conn->options.flags & CLIENT_LOCAL_FILES)) {
! 188: php_error_docref(NULL TSRMLS_CC, E_WARNING, "LOAD DATA LOCAL INFILE forbidden");
! 189: /* write empty packet to server */
! 190: ret = conn->net->m.send(conn, empty_packet, 0 TSRMLS_CC);
! 191: *is_warning = TRUE;
! 192: goto infile_error;
! 193: }
! 194:
! 195: infile = conn->infile;
! 196: /* allocate buffer for reading data */
! 197: buf = (char *)mnd_ecalloc(1, buflen);
! 198:
! 199: *is_warning = FALSE;
! 200:
! 201: /* init handler: allocate read buffer and open file */
! 202: if (infile.local_infile_init(&info, (char *)filename, conn->infile.userdata TSRMLS_CC)) {
! 203: *is_warning = TRUE;
! 204: /* error occured */
! 205: strcpy(conn->error_info.sqlstate, UNKNOWN_SQLSTATE);
! 206: conn->error_info.error_no =
! 207: infile.local_infile_error(info, conn->error_info.error, sizeof(conn->error_info.error) TSRMLS_CC);
! 208: /* write empty packet to server */
! 209: ret = conn->net->m.send(conn, empty_packet, 0 TSRMLS_CC);
! 210: goto infile_error;
! 211: }
! 212:
! 213: /* read data */
! 214: while ((bufsize = infile.local_infile_read (info, buf + MYSQLND_HEADER_SIZE, buflen - MYSQLND_HEADER_SIZE TSRMLS_CC)) > 0) {
! 215: if ((ret = conn->net->m.send(conn, buf, bufsize TSRMLS_CC)) == 0) {
! 216: DBG_ERR_FMT("Error during read : %d %s %s", CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn);
! 217: SET_CLIENT_ERROR(conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn);
! 218: goto infile_error;
! 219: }
! 220: }
! 221:
! 222: /* send empty packet for eof */
! 223: if ((ret = conn->net->m.send(conn, empty_packet, 0 TSRMLS_CC)) == 0) {
! 224: SET_CLIENT_ERROR(conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn);
! 225: goto infile_error;
! 226: }
! 227:
! 228: /* error during read occured */
! 229: if (bufsize < 0) {
! 230: *is_warning = TRUE;
! 231: DBG_ERR_FMT("Bufsize < 0, warning, %d %s %s", CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn);
! 232: strcpy(conn->error_info.sqlstate, UNKNOWN_SQLSTATE);
! 233: conn->error_info.error_no =
! 234: infile.local_infile_error(info, conn->error_info.error, sizeof(conn->error_info.error) TSRMLS_CC);
! 235: goto infile_error;
! 236: }
! 237:
! 238: result = PASS;
! 239:
! 240: infile_error:
! 241: /* get response from server and update upsert values */
! 242: if (FAIL == conn->m->simple_command_handle_response(conn, PROT_OK_PACKET, FALSE, COM_QUERY, FALSE TSRMLS_CC)) {
! 243: result = FAIL;
! 244: }
! 245:
! 246: (*conn->infile.local_infile_end)(info TSRMLS_CC);
! 247: if (buf) {
! 248: mnd_efree(buf);
! 249: }
! 250: DBG_INF_FMT("%s", result == PASS? "PASS":"FAIL");
! 251: DBG_RETURN(result);
! 252: }
! 253: /* }}} */
! 254:
! 255: /*
! 256: * Local variables:
! 257: * tab-width: 4
! 258: * c-basic-offset: 4
! 259: * End:
! 260: * vim600: noet sw=4 ts=4 fdm=marker
! 261: * vim<600: noet sw=4 ts=4
! 262: */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mysqlnd_loaddata.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / mysqlnd