connect_errno) { echo "

connect to doris failed. " . $conn->connect_errno . "

"; } echo "

connect to doris successfully

"; # create database $sql = "CREATE DATABASE IF NOT EXISTS " . $database; if ($conn->query($sql) === TRUE) { echo "

create database successfully

"; } else { echo "

create database failed. " . $conn->error . "

"; } # set db context if ($conn->select_db($database) === TRUE) { echo "

set db context successfully

"; } else { echo "

set db context failed. " . $conn->error . "

"; } # create table $sql = "CREATE TABLE IF NOT EXISTS table_test(siteid INT, citycode SMALLINT, pv BIGINT SUM) " . "AGGREGATE KEY(siteid, citycode) " . "DISTRIBUTED BY HASH(siteid) BUCKETS 10 " . "PROPERTIES(\"replication_num\" = \"1\")"; if ($conn->query($sql) === TRUE) { echo "

create table successfully

"; } else { echo "

create table failed. " . $conn->error . "

"; } # insert data $sql = "INSERT INTO table_test values(1, 2, 3), (4, 5, 6), (1, 2, 4)"; if ($conn->query($sql) === TRUE) { echo "

insert data successfully

"; } else { echo "

insert data failed. " . $conn->error . "

"; } # query data $sql = "SELECT siteid, citycode, pv FROM table_test"; $result = $conn->query($sql); if ($result) { echo "

query data successfully

"; echo ""; while($row = $result->fetch_assoc()) { echo ""; } echo "

siteid	citycode	pv
" . $row["siteid"] . "	" . $row["citycode"] . "	" . $row["pv"] . "

"; } else { echo "

query data failed. " . $conn->error . "

"; } # drop database $sql = "DROP DATABASE IF EXISTS " . $database; if ($conn->query($sql) === TRUE) { echo "

drop database successfully

"; } else { echo "

drop database failed. " . $conn->error . "

"; } # close connection $conn->close(); ?>