~azzar1/unity/add-show-desktop-key

$this->db_connect_id = ($this->persistency) ? @mysql_pconnect($this->server, $this->user, $sqlpassword, $new_link) : @mysql_connect($this->server, $this->user, $sqlpassword, $new_link);

if ($this->db_connect_id && $this->dbname != '')

{

if (@mysql_select_db($this->dbname, $this->db_connect_id))

{

// Determine what version we are using and if it natively supports UNICODE

$this->mysql_version = mysql_get_server_info($this->db_connect_id);

if (version_compare($this->mysql_version, '4.1.3', '>='))

{

@mysql_query("SET NAMES 'utf8'", $this->db_connect_id);

// enforce strict mode on databases that support it

if (version_compare($this->mysql_version, '5.0.2', '>='))

{

$result = @mysql_query('SELECT @@session.sql_mode AS sql_mode', $this->db_connect_id);

$row = @mysql_fetch_assoc($result);

@mysql_free_result($result);

$modes = array_map('trim', explode(',', $row['sql_mode']));

// TRADITIONAL includes STRICT_ALL_TABLES and STRICT_TRANS_TABLES

if (!in_array('TRADITIONAL', $modes))

{

if (!in_array('STRICT_ALL_TABLES', $modes))

{

$modes[] = 'STRICT_ALL_TABLES';

}

if (!in_array('STRICT_TRANS_TABLES', $modes))

{

$modes[] = 'STRICT_TRANS_TABLES';

}

$mode = implode(',', $modes);

@mysql_query("SET SESSION sql_mode='{$mode}'", $this->db_connect_id);

}

else if (version_compare($this->mysql_version, '4.0.0', '<'))

{

$this->sql_layer = 'mysql';

}

return $this->db_connect_id;

}

return $this->sql_error('');

}

/**

* Version information about used database

100

101

function sql_server_info()

102

{

103

return 'MySQL ' . $this->mysql_version;

104

}

105

106

/**

107

* SQL Transaction

108

* @access private

109

110

function _sql_transaction($status = 'begin')

111

{

112

switch ($status)

113

{

114

case 'begin':

115

return @mysql_query('BEGIN', $this->db_connect_id);

116

break;

117

118

case 'commit':

119

return @mysql_query('COMMIT', $this->db_connect_id);

120

break;

121

122

case 'rollback':

123

return @mysql_query('ROLLBACK', $this->db_connect_id);

124

break;

125

}

126

127

return true;

128

}

129

130

/**

131

* Base query method

132

133

* @param string $query Contains the SQL query which shall be executed

134

* @param int $cache_ttl Either 0 to avoid caching or the time in seconds which the result shall be kept in cache

135

* @return mixed When casted to bool the returned value returns true on success and false on failure

136

137

* @access public

138

139

function sql_query($query = '', $cache_ttl = 0)

140

{

141

if ($query != '')

142

{

143

global $cache;

144

145

// EXPLAIN only in extra debug mode

146

if (defined('DEBUG_EXTRA'))

147

{

148

$this->sql_report('start', $query);

149

}

150

151

$this->query_result = ($cache_ttl && method_exists($cache, 'sql_load')) ? $cache->sql_load($query) : false;

152

$this->sql_add_num_queries($this->query_result);

153

154

if ($this->query_result === false)

155

{

156

if (($this->query_result = @mysql_query($query, $this->db_connect_id)) === false)

157

{

158

$this->sql_error($query);

159

}

160

161

if (defined('DEBUG_EXTRA'))

162

{

163

$this->sql_report('stop', $query);

164

}

165

166

if ($cache_ttl && method_exists($cache, 'sql_save'))

167

{

168

$this->open_queries[(int) $this->query_result] = $this->query_result;

169

$cache->sql_save($query, $this->query_result, $cache_ttl);

170

}

171

else if (strpos($query, 'SELECT') === 0 && $this->query_result)

172

{

173

$this->open_queries[(int) $this->query_result] = $this->query_result;

174

}

175

}

176

else if (defined('DEBUG_EXTRA'))

177

{

178

$this->sql_report('fromcache', $query);

179

}

180

}

181

else

182

{

183

return false;

184

}

185

186

return ($this->query_result) ? $this->query_result : false;

187

}

188

189

/**

190

* Build LIMIT query

191

192

function _sql_query_limit($query, $total, $offset = 0, $cache_ttl = 0)

193

{

194

$this->query_result = false;

195

196

// if $total is set to 0 we do not want to limit the number of rows

197

if ($total == 0)

198

{

199

// Having a value of -1 was always a bug

200

$total = '18446744073709551615';

201

}

202

203

$query .= "\n LIMIT " . ((!empty($offset)) ? $offset . ', ' . $total : $total);

204

205

return $this->sql_query($query, $cache_ttl);

206

}

207

208

/**

209

* Return number of affected rows

210

211

function sql_affectedrows()

212

{

213

return ($this->db_connect_id) ? @mysql_affected_rows($this->db_connect_id) : false;

214

}

215

216

/**

217

* Fetch current row

218

219

function sql_fetchrow($query_id = false)

220

{

221

global $cache;

222

223

if ($query_id === false)

224

{

225

$query_id = $this->query_result;

226

}

227

228

if (isset($cache->sql_rowset[$query_id]))

229

{

230

return $cache->sql_fetchrow($query_id);

231

}

232

233

return ($query_id !== false) ? @mysql_fetch_assoc($query_id) : false;

234

}

235

236

/**

237

* Seek to given row number

238

* rownum is zero-based

239

240

function sql_rowseek($rownum, &$query_id)

241

{

242

global $cache;

243

244

if ($query_id === false)

245

{

246

$query_id = $this->query_result;

247

}

248

249

if (isset($cache->sql_rowset[$query_id]))

250

{

251

return $cache->sql_rowseek($rownum, $query_id);

252

}

253

254

return ($query_id !== false) ? @mysql_data_seek($query_id, $rownum) : false;

255

}

256

257

/**

258

* Get last inserted id after insert statement

259

260

function sql_nextid()

261

{

262

return ($this->db_connect_id) ? @mysql_insert_id($this->db_connect_id) : false;

263

}

264

265

/**

266

* Free sql result

267

268

function sql_freeresult($query_id = false)

269

{

270

global $cache;

271

272

if ($query_id === false)

273

{

274

$query_id = $this->query_result;

275

}

276

277

if (isset($cache->sql_rowset[$query_id]))

278

{

279

return $cache->sql_freeresult($query_id);

280

}

281

282

if (isset($this->open_queries[(int) $query_id]))

283

{

284

unset($this->open_queries[(int) $query_id]);

285

return @mysql_free_result($query_id);

286

}

287

288

return false;

289

}

290

291

/**

292

* Escape string used in sql query

293

294

function sql_escape($msg)

295

{

296

if (!$this->db_connect_id)

297

{

298

return @mysql_real_escape_string($msg);

299

}

300

301

return @mysql_real_escape_string($msg, $this->db_connect_id);

302

}

303

304

/**

305

* Build LIKE expression

306

* @access private

307

308

function _sql_like_expression($expression)

309

{

310

return $expression;

311

}

312

313

/**

314

* Build db-specific query data

315

* @access private

316

317

function _sql_custom_build($stage, $data)

318

{

319

switch ($stage)

320

{

321

case 'FROM':

322

$data = '(' . $data . ')';

323

break;

324

}

325

326

return $data;

327

}

328

329

/**

330

* return sql error array

331

* @access private

332

333

function _sql_error()

334

{

335

if (!$this->db_connect_id)

336

{

337

return array(

338

'message' => @mysql_error(),

339

'code' => @mysql_errno()

340

);

341

}

342

343

return array(

344

'message' => @mysql_error($this->db_connect_id),

345

'code' => @mysql_errno($this->db_connect_id)

346

);

347

}

348

349

/**

350

* Close sql connection

351

* @access private

352

353

function _sql_close()

354

{

355

return @mysql_close($this->db_connect_id);

356

}

357

358

/**

359

* Build db-specific report

360

* @access private

361

362

function _sql_report($mode, $query = '')

363

{

364

static $test_prof;

365

366

// current detection method, might just switch to see the existance of INFORMATION_SCHEMA.PROFILING

367

if ($test_prof === null)

368

{

369

$test_prof = false;

370

if (strpos($this->mysql_version, 'community') !== false)

371

{

372

$ver = substr($this->mysql_version, 0, strpos($this->mysql_version, '-'));

373

if (version_compare($ver, '5.0.37', '>=') && version_compare($ver, '5.1', '<'))

374

{

375

$test_prof = true;

376

}

377

}

378

}

379

380

switch ($mode)

381

{

382

case 'start':

383

384

$explain_query = $query;

385

if (preg_match('/UPDATE ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))

386

{

387

$explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];

388

}

389

else if (preg_match('/DELETE FROM ([a-z0-9_]+).*?WHERE(.*)/s', $query, $m))

390

{

391

$explain_query = 'SELECT * FROM ' . $m[1] . ' WHERE ' . $m[2];

392

}

393

394

if (preg_match('/^SELECT/', $explain_query))

395

{

396

$html_table = false;

397

398

// begin profiling

399

if ($test_prof)

400

{

401

@mysql_query('SET profiling = 1;', $this->db_connect_id);

402

}

403

404

if ($result = @mysql_query("EXPLAIN $explain_query", $this->db_connect_id))

405

{

406

while ($row = @mysql_fetch_assoc($result))

407

{

408

$html_table = $this->sql_report('add_select_row', $query, $html_table, $row);

409

}

410

}

411

@mysql_free_result($result);

412

413

if ($html_table)

414

{

415

$this->html_hold .= '</table>';

416

}

417

418

if ($test_prof)

419

{

420

$html_table = false;

421

422

// get the last profile

423

if ($result = @mysql_query('SHOW PROFILE ALL;', $this->db_connect_id))

424

{

425

$this->html_hold .= '<br />';

426

while ($row = @mysql_fetch_assoc($result))

427

{

428

// make <unknown> HTML safe

429

if (!empty($row['Source_function']))

430

{

431

$row['Source_function'] = str_replace(array('<', '>'), array('<', '>'), $row['Source_function']);

432

}

433

434

// remove unsupported features

435

foreach ($row as $key => $val)

436

{

437

if ($val === null)

438

{

439

unset($row[$key]);

440

}

441

}

442

$html_table = $this->sql_report('add_select_row', $query, $html_table, $row);

443

}

444

}

445

@mysql_free_result($result);

446

447

if ($html_table)

448

{

449

$this->html_hold .= '</table>';

450

}

451

452

@mysql_query('SET profiling = 0;', $this->db_connect_id);

453

}

454

}

455

456

break;

457

458

case 'fromcache':

459

$endtime = explode(' ', microtime());

460

$endtime = $endtime[0] + $endtime[1];

461

462

$result = @mysql_query($query, $this->db_connect_id);

463

while ($void = @mysql_fetch_assoc($result))

464

{

465

// Take the time spent on parsing rows into account

466

}

467

@mysql_free_result($result);

468

469

$splittime = explode(' ', microtime());

470

$splittime = $splittime[0] + $splittime[1];

471

472

$this->sql_report('record_fromcache', $query, $endtime, $splittime);

473

474

break;

475

}

476

}

477

}

478

479

b'\\ No newline at end of file'

Older »