Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F85595210
AphrontMySQLDatabaseConnection.php
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Subscribers
None
File Metadata
Details
File Info
Storage
Attached
Created
Mon, Sep 30, 04:53
Size
5 KB
Mime Type
text/x-php
Expires
Wed, Oct 2, 04:53 (1 d, 21 h)
Engine
blob
Format
Raw Data
Handle
21213647
Attached To
rPHU libphutil
AphrontMySQLDatabaseConnection.php
View Options
<?php
/**
* @group storage
*/
final
class
AphrontMySQLDatabaseConnection
extends
AphrontMySQLDatabaseConnectionBase
{
public
function
escapeString
(
$string
)
{
return
mysql_real_escape_string
(
$string
,
$this
->
requireConnection
());
}
public
function
getInsertID
()
{
return
mysql_insert_id
(
$this
->
requireConnection
());
}
public
function
getAffectedRows
()
{
return
mysql_affected_rows
(
$this
->
requireConnection
());
}
protected
function
closeConnection
()
{
mysql_close
(
$this
->
requireConnection
());
}
protected
function
connect
()
{
if
(!
function_exists
(
'mysql_connect'
))
{
// We have to '@' the actual call since it can spew all sorts of silly
// noise, but it will also silence fatals caused by not having MySQL
// installed, which has bitten me on three separate occasions. Make sure
// such failures are explicit and loud.
throw
new
Exception
(
"About to call mysql_connect(), but the PHP MySQL extension is not "
.
"available!"
);
}
$user
=
$this
->
getConfiguration
(
'user'
);
$host
=
$this
->
getConfiguration
(
'host'
);
$database
=
$this
->
getConfiguration
(
'database'
);
$pass
=
$this
->
getConfiguration
(
'pass'
);
if
(
$pass
instanceof
PhutilOpaqueEnvelope
)
{
$pass
=
$pass
->
openEnvelope
();
}
$conn
=
@
mysql_connect
(
$host
,
$user
,
$pass
,
$new_link
=
true
,
$flags
=
0
);
if
(!
$conn
)
{
$errno
=
mysql_errno
();
$error
=
mysql_error
();
throw
new
AphrontQueryConnectionException
(
"Attempt to connect to {$user}@{$host} failed with error "
.
"#{$errno}: {$error}."
,
$errno
);
}
if
(
$database
!==
null
)
{
$ret
=
@
mysql_select_db
(
$database
,
$conn
);
if
(!
$ret
)
{
$this
->
throwQueryException
(
$conn
);
}
}
mysql_set_charset
(
'utf8'
,
$conn
);
return
$conn
;
}
protected
function
rawQuery
(
$raw_query
)
{
return
@
mysql_query
(
$raw_query
,
$this
->
requireConnection
());
}
/**
* @phutil-external-symbol function mysql_multi_query
* @phutil-external-symbol function mysql_fetch_result
* @phutil-external-symbol function mysql_more_results
* @phutil-external-symbol function mysql_next_result
*/
protected
function
rawQueries
(
array
$raw_queries
)
{
$conn
=
$this
->
requireConnection
();
$results
=
array
();
if
(!
function_exists
(
'mysql_multi_query'
))
{
foreach
(
$raw_queries
as
$key
=>
$raw_query
)
{
$results
[
$key
]
=
$this
->
processResult
(
$this
->
rawQuery
(
$raw_query
));
}
return
$results
;
}
if
(!
mysql_multi_query
(
implode
(
"
\n
;
\n\n
"
,
$raw_queries
),
$conn
))
{
$ex
=
$this
->
processResult
(
false
);
return
array_fill_keys
(
array_keys
(
$raw_queries
),
$ex
);
}
$processed_all
=
false
;
foreach
(
$raw_queries
as
$key
=>
$raw_query
)
{
$results
[
$key
]
=
$this
->
processResult
(@
mysql_fetch_result
(
$conn
));
if
(!
mysql_more_results
(
$conn
))
{
$processed_all
=
true
;
break
;
}
mysql_next_result
(
$conn
);
}
if
(!
$processed_all
)
{
throw
new
Exception
(
"There are some results left in the result set."
);
}
return
$results
;
}
protected
function
freeResult
(
$result
)
{
mysql_free_result
(
$result
);
}
public
function
supportsParallelQueries
()
{
// fb_parallel_query() doesn't support results with different columns.
return
false
;
}
/**
* @phutil-external-symbol function fb_parallel_query
*/
public
function
executeParallelQueries
(
array
$queries
,
array
$conns
=
array
())
{
assert_instances_of
(
$conns
,
'AphrontMySQLDatabaseConnection'
);
$map
=
array
();
$is_write
=
false
;
foreach
(
$queries
as
$id
=>
$query
)
{
$is_write
=
$is_write
||
$this
->
checkWrite
(
$query
);
$conn
=
idx
(
$conns
,
$id
,
$this
);
$host
=
$conn
->
getConfiguration
(
'host'
);
$port
=
0
;
$match
=
null
;
if
(
preg_match
(
'/(.+):(.+)/'
,
$host
,
$match
))
{
list
(,
$host
,
$port
)
=
$match
;
}
$pass
=
$conn
->
getConfiguration
(
'pass'
);
if
(
$pass
instanceof
PhutilOpaqueEnvelope
)
{
$pass
=
$pass
->
openEnvelope
();
}
$map
[
$id
]
=
array
(
'sql'
=>
$query
,
'ip'
=>
$host
,
'port'
=>
$port
,
'username'
=>
$conn
->
getConfiguration
(
'user'
),
'password'
=>
$pass
,
'db'
=>
$conn
->
getConfiguration
(
'database'
),
);
}
$profiler
=
PhutilServiceProfiler
::
getInstance
();
$call_id
=
$profiler
->
beginServiceCall
(
array
(
'type'
=>
'multi-query'
,
'queries'
=>
$queries
,
'write'
=>
$is_write
,
));
$map
=
fb_parallel_query
(
$map
);
$profiler
->
endServiceCall
(
$call_id
,
array
());
$results
=
array
();
$pos
=
0
;
$err_pos
=
0
;
foreach
(
$queries
as
$id
=>
$query
)
{
$errno
=
idx
(
idx
(
$map
,
'errno'
,
array
()),
$err_pos
);
$err_pos
++;
if
(
$errno
)
{
try
{
$this
->
throwQueryCodeException
(
$errno
,
$map
[
'error'
][
$id
]);
}
catch
(
Exception
$ex
)
{
$results
[
$id
]
=
$ex
;
}
continue
;
}
$results
[
$id
]
=
$map
[
'result'
][
$pos
];
$pos
++;
}
return
$results
;
}
protected
function
fetchAssoc
(
$result
)
{
return
mysql_fetch_assoc
(
$result
);
}
protected
function
getErrorCode
(
$connection
)
{
return
mysql_errno
(
$connection
);
}
protected
function
getErrorDescription
(
$connection
)
{
return
mysql_error
(
$connection
);
}
}
Event Timeline
Log In to Comment