包 | XS.util |
---|---|
继承关系 | class XSCsvDataSource » XSDataSource |
版本 | 1.0.0 |
源代码 | sdk/php/util/XSDataSource.class.php |
名称 | 描述 | 定义于 |
---|---|---|
__construct() | 构造函数 | XSDataSource |
getCharset() | 取得数据源的准确字符集 | XSDataSource |
getData() | 从数据源中提取一条数据 | XSDataSource |
instance() | 取得数据源对象实例 | XSDataSource |
名称 | 描述 | 定义于 |
---|---|---|
deinit() | XSCsvDataSource | |
getDataList() | XSCsvDataSource | |
init() | XSCsvDataSource |
protected void deinit()
|
protected function deinit()
{
if ($this->fd) {
fclose($this->fd);
$this->fd = null;
}
}
protected void getDataList()
|
protected function getDataList()
{
if (($item = fgetcsv($this->fd, 0, $this->delim)) === false) {
if ($this->inCli) {
echo "INFO: reach end of file or error occured, total lines: " . $this->line . "\n";
}
return false;
}
$this->line++;
if (count($item) === 1 && is_null($item[0])) {
if ($this->inCli) {
echo "WARNING: invalid csv line #" . $this->line . "\n";
}
$this->invalidLines++;
return $this->getDataList();
}
return array($item);
}
protected void init()
|
protected function init()
{
$file = $this->arg;
if (empty($file) && $this->inCli) {
echo "WARNING: input file not specified, read data from <STDIN>\n";
$file = 'php://stdin';
}
if (!($this->fd = fopen($file, 'r'))) {
throw new XSException("Can not open input file: '$file'");
}
$this->line = 0;
if (isset($_SERVER['XS_CSV_DELIMITER'])) {
$this->delim = $_SERVER['XS_CSV_DELIMITER'];
}
}
包 | XS.util |
---|---|
继承关系 | class XSCsvDataSource » XSDataSource |
版本 | 1.0.0 |
源代码 | sdk/php/util/XSDataSource.class.php |
名称 | 描述 | 定义于 |
---|---|---|
__construct() | 构造函数 | XSDataSource |
getCharset() | 取得数据源的准确字符集 | XSDataSource |
getData() | 从数据源中提取一条数据 | XSDataSource |
instance() | 取得数据源对象实例 | XSDataSource |
名称 | 描述 | 定义于 |
---|---|---|
deinit() | XSCsvDataSource | |
getDataList() | XSCsvDataSource | |
init() | XSCsvDataSource |
protected void deinit()
|
protected function deinit()
{
if ($this->fd) {
fclose($this->fd);
$this->fd = null;
}
}
protected void getDataList()
|
protected function getDataList()
{
if (($item = fgetcsv($this->fd, 0, $this->delim)) === false) {
if ($this->inCli) {
echo "INFO: reach end of file or error occured, total lines: " . $this->line . "\n";
}
return false;
}
$this->line++;
if (count($item) === 1 && is_null($item[0])) {
if ($this->inCli) {
echo "WARNING: invalid csv line #" . $this->line . "\n";
}
$this->invalidLines++;
return $this->getDataList();
}
return array($item);
}
protected void init()
|
protected function init()
{
$file = $this->arg;
if (empty($file) && $this->inCli) {
echo "WARNING: input file not specified, read data from <STDIN>\n";
$file = 'php://stdin';
}
if (!($this->fd = fopen($file, 'r'))) {
throw new XSException("Can not open input file: '$file'");
}
$this->line = 0;
if (isset($_SERVER['XS_CSV_DELIMITER'])) {
$this->delim = $_SERVER['XS_CSV_DELIMITER'];
}
}
留下一条评论吧!
请到论坛 登录 后刷新本页面!