Problema:
Para insertar multiples datos a "X" tabla
, estoy tratando de crear un metodo que haga que el bindParam
sea dinamico, pero tengo muchos errores y no consigo concatenar los datos de manera correcta, mi amigo foreach
falla y no hayo la forma de recorrer 2 arrays al mismo tiempo y que los campos y valores queden relacionados. Aclaro que al escribir todas las filas de manera manual me funciona y puedo ingresar los datos a la Db
sin probelmas. Pero en caso de tablas con muchas columnas si necesito que esto sea automatico.
Lo que he intentado:
He creado un array
con todos los campos
de la tabla
y una clase
que devuelve un objeto
con todos los metodos
que retornan los valores
para ingresar a la DB
.
inmediatamente recibo el arreglo
y el objeto
por parametros
, trato de recorrelos con un foreach
o un for
pero no logro relacionarlos.
Por ultimo he probado con array_merge()
pero genera un error que supongo es por el objeto que tiene los valores que necesito ingresar.
Este es el codigo ejemplo de lo que intento hacer:
//$sql es la sentencia del INSERT
//Ej.(INSERT INTO users(nick_user) VALUES (:nick_user))
//$users es el objeto con los valores a ingresar
//Ej($users->get_nickUser())
//$valuesParams es el arreglo con las columnas de la tabla, ya vienen con los ":"
//Ej.(:name_user)
//Test 1:
public function userCreate($con,$sql,$users,$valuesParams) //Registrar Usuario
{
$this->stmt=$con->prepare($sql);
$this->stmt->execute(array_merge($valuesParams,$users));
}
//test 2:
foreach ($users as $v) {
foreach($valuesParams as $k){
$get=$v;
// $this->stmt->bindParam($k,$get,PDO::PARAM_STR);
}
echo $k++ .'<br>';
echo $get.'<br>';
// $this->stmt->bindParam($k,$get,PDO::PARAM_STR);
}
//Codigo nuevo error
$con = new ConDb($files);
$con1 = $con->con();
class DBTables
{
private $tables =
array(
"user_app" =>
array(
"columns" =>
array(
"user_id" => PDO::PARAM_INT,
"user_name" => PDO::PARAM_STR,
"user_lastname" => PDO::PARAM_STR,
)
),
"film" =>
array(
"columns" =>
array(
"film_id" => PDO::PARAM_INT,
"title" => PDO::PARAM_STR,
"description" => PDO::PARAM_STR,
"film_year" => PDO::PARAM_INT,
"language_id" => PDO::PARAM_INT,
)
),
);
public function __construct()
{
}
public function prepareQuery($tableName)
{
$table = $this->tables[$tableName] ?? null;
if (!$table) {
throw new Exception("La tabla $tableName no existe.");
}
$columns = array_keys($table["columns"]);
$sql = sprintf(
"INSERT INTO %s (%s) VALUES (%s)",
$tableName,
implode(",", $columns),
sprintf("%s%s", ":", implode(",:", $columns))
);
return array("query" => $sql, "columns" => $table['columns']);
}
}
$tableName = "user_app";
$users = array(
array("user_id" => 33, "user_name" => "Pedro", "user_lastname" => "Díaz"),
array("user_id" => 22, "user_name" => "Marta", "user_lastname" => "Pérez"),
);
try {
$dbTables = new DBTables();
$queryWithColumns = $dbTables->prepareQuery($tableName);
$stmt = $con1->prepare($queryWithColumns["query"]);
foreach ($users as $row) {
foreach ($row as $column => &$value) {
//Esta es la linea del error PDOStatement::bindParam() expects at least 2 arguments, 1 given in
$stmt->bindParam(sprintf(":%s %s %d", $column, $value, $queryWithColumns["columns"][$column]));
}
$stmt->execute();
}
} catch (Exception $e) {
echo $e->getMessage();
}