Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <?php
- $databasehost = "localhost";
- $databasename = "test2";
- $databasetable = "voters";
- $databaseusername="root";
- $databasepassword = "";
- $fieldseparator = ",";
- $fieldstartend = '"';
- $lineseparator = "\r";
- $csvfile = "AllVoters_01122016.csv";
- if(!file_exists($csvfile)) {
- die("File not found. Make sure you specified the correct path.");
- }
- try {
- $pdo = new PDO("mysql:host=$databasehost;dbname=$databasename",
- $databaseusername, $databasepassword,
- array(
- PDO::MYSQL_ATTR_LOCAL_INFILE => true,
- PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
- )
- );
- } catch (PDOException $e) {
- die("database connection failed: ".$e->getMessage());
- }
- $affectedRows = $pdo->exec("
- LOAD DATA LOCAL INFILE ".$pdo->quote($csvfile)." INTO TABLE `$databasetable`
- FIELDS TERMINATED BY ".$pdo->quote($fieldseparator)." ENCLOSED BY ".$pdo->quote($fieldstartend)."
- LINES TERMINATED BY ".$pdo->quote($lineseparator));
- echo "Loaded a total of $affectedRows records from this csv file.\n";
- ?>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement