← All changes | classes/Visualizer/Source/Query.php +80 -41 3.1.0 → 3.4.8 View file →

		@@ -35,23 +35,35 @@
35	35	*/
36	36	protected $_query;
37	37
38	38	/**
39		- * The error message.
	39	+ * The chart id.
40	40	*
41	41	* @access protected
42		- * @var string
	42	+ * @var int
43	43	*/
44		- protected $_error;
	44	+ protected $_chart_id;
45	45
46	46	/**
	47	+ * Any additional parameters (e.g. for connecting to a remote db).
	48	+ *
	49	+ * @access protected
	50	+ * @var array
	51	+ */
	52	+ protected $_params;
	53	+
	54	+ /**
47	55	* Constructor.
48	56	*
49	57	* @access public
50	58	* @param string $query The query.
	59	+ * @param int $chart_id The chart id.
	60	+ * @param array $params Any additional parameters (e.g. for connecting to a remote db).
51	61	*/
52		- public function __construct( $query = null ) {
	62	+ public function __construct( $query = null, $chart_id = null, $params = null ) {
53	63	$this->_query = $query;
	64	+ $this->_chart_id = $chart_id;
	65	+ $this->_params = $params;
54	66	}
55	67
56	68	/**
57	69	* Fetches information from source, parses it and builds series and data arrays.
		@@ -56,55 +68,92 @@
56	68	/**
57	69	* Fetches information from source, parses it and builds series and data arrays.
58	70	*
59	71	* @param bool $as_html Should the result be fetched as an HTML table or as an object.
	72	+ * @param bool $results_as_numeric_array Should the result be fetched as ARRAY_N instead of ARRAY_A.
	73	+ * @param bool $raw_results Should the result be returned without processing.
60	74	* @access public
61	75	* @return boolean TRUE on success, otherwise FALSE.
62	76	*/
63		- public function fetch( $as_html = false ) {
	77	+ public function fetch( $as_html = false, $results_as_numeric_array = false, $raw_results = false ) {
64	78	if ( empty( $this->_query ) ) {
65	79	return false;
66	80	}
67	81
	82	+ // only select queries allowed.
	83	+ if ( preg_match( '/^\s*(insert|delete|update|replace|create|alter|drop|truncate)\s/i', $this->_query ) ) {
	84	+ $this->_error = __( 'Only SELECT queries are allowed', 'visualizer' );
	85	+ return false;
	86	+ }
	87	+
68	88	// impose a limit if no limit clause is provided.
69	89	if ( strpos( strtolower( $this->_query ), ' limit ' ) === false ) {
70		- $this->_query .= ' LIMIT ' . apply_filters( 'visualizer_sql_query_limit', 300 );
	90	+ $this->_query .= ' LIMIT ' . apply_filters( 'visualizer_sql_query_limit', 1000, $this->_chart_id );
71	91	}
72	92
73		- global $wpdb;
74		- $wpdb->hide_errors();
75		- // @codingStandardsIgnoreStart
76		- $rows = $wpdb->get_results( $this->_query, ARRAY_A );
77		- // @codingStandardsIgnoreEnd
78		- $wpdb->show_errors();
	93	+ $this->_query = apply_filters( 'visualizer_db_query', $this->_query, $this->_chart_id, $this->_params );
79	94
80		- if ( $rows ) {
81		- $results = array();
82		- $headers = array();
	95	+ $results = array();
	96	+ $headers = array();
	97	+
	98	+ // short circuit results for remote dbs.
	99	+ if ( false !== ( $remote_results = apply_filters( 'visualizer_db_query_execute', false, $this->_query, $as_html, $results_as_numeric_array, $raw_results, $this->_chart_id, $this->_params ) ) ) {
	100	+ $error = $remote_results['error'];
	101	+ if ( empty( $error ) ) {
	102	+ $results = $remote_results['results'];
	103	+ $headers = $remote_results['headers'];
	104	+ }
	105	+
	106	+ $this->_error = $error;
	107	+
	108	+ if ( $raw_results ) {
	109	+ return $results;
	110	+ }
	111	+ }
	112	+
	113	+ if ( ! ( $results && $headers ) ) {
	114	+ global $wpdb;
	115	+ $wpdb->hide_errors();
	116	+ // @codingStandardsIgnoreStart
	117	+ $rows = $wpdb->get_results( $this->_query, $results_as_numeric_array ? ARRAY_N : ARRAY_A );
	118	+ do_action( 'themeisle_log_event', Visualizer_Plugin::NAME, sprintf( 'Firing query %s to get results %s with error %s', $this->_query, print_r( $rows, true ), print_r( $wpdb->last_error, true ) ), 'debug', __FILE__, __LINE__ );
	119	+ // @codingStandardsIgnoreEnd
	120	+ $wpdb->show_errors();
	121	+
	122	+ if ( $raw_results ) {
	123	+ return $rows;
	124	+ }
	125	+
83	126	if ( $rows ) {
84		- $row_num = 0;
85		- foreach ( $rows as $row ) {
86		- $result = array();
87		- $col_num = 0;
88		- foreach ( $row as $k => $v ) {
89		- $result[] = $v;
90		- if ( 0 === $row_num ) {
91		- $headers[] = array( 'type' => $this->get_col_type( $col_num++ ), 'label' => $k );
	127	+ $results = array();
	128	+ $headers = array();
	129	+ if ( $rows ) {
	130	+ $row_num = 0;
	131	+ foreach ( $rows as $row ) {
	132	+ $result = array();
	133	+ $col_num = 0;
	134	+ foreach ( $row as $k => $v ) {
	135	+ $result[] = $v;
	136	+ if ( 0 === $row_num ) {
	137	+ $headers[] = array( 'type' => $this->get_col_type( $col_num++ ), 'label' => $k );
	138	+ }
92	139	}
	140	+ $results[] = $result;
	141	+ $row_num++;
93	142	}
94		- $results[] = $result;
95		- $row_num++;
96	143	}
	144	+
	145	+ $this->_error = $wpdb->last_error;
97	146	}
	147	+ }
98	148
99		- if ( $as_html ) {
100		- return $this->html( $headers, $results );
101		- }
102		- return $this->object( $headers, $results );
	149	+ if ( $as_html ) {
	150	+ $results = $this->html( $headers, $results );
	151	+ } else {
	152	+ $results = $this->object( $headers, $results );
103	153	}
104	154
105		- $this->_error = $wpdb->last_error;
106		- return null;
	155	+ return apply_filters( 'visualizer_db_query_results', $results, $headers, $as_html, $results_as_numeric_array, $raw_results, $this->_query, $this->_chart_id, $this->_params );
107	156	}
108	157
109	158	/**
110	159	* Get the data type of the column.
		@@ -168,18 +217,8 @@
168	217	}
169	218	$this->_data = $data;
170	219
171	220	return true;
172		- }
173		-
174		- /**
175		- * Returns the error, if any.
176		- *
177		- * @access public
178		- * @return string
179		- */
180		- public function get_error() {
181		- return $this->_error;
182	221	}
183	222
184	223	/**
185	224	* Returns the final query.