Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <?php
- $databasehost = "localhost";
- $databasename = "test";
- $databasetable = "sample";
- $databaseusername="test";
- $databasepassword = "";
- $fieldseparator = ",";
- $lineseparator = "\n";
- $csvfile = "filename.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)
- ."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