Cómo insertar un registro en una tabla MySQL y obtener, en la misma acción, el valor del campo clave primaria (primary key) del nuevo registro insertado, en Visual Studio .NET C Sharp (C#). Útil cuando insertamos un registro en una tabla y queremos seguir trabajando en el mismo código fuente con el registro insertado, para ello hay que conocer su clave primaria.
- Ejemplo de tabla MySQL con clave primaria autonumérica.
- Código fuente C# para insertar un registro en una tabla.
- Código fuente C# para insertar un registro en una tabla y obtener el valor del campo clave primaria del registro insertado.
Ejemplo de tabla MySQL con clave primaria autonumérica
Como ejemplo, supongamos que tenemos la siguiente tabla en MySQL:
|
1 2 3 4 5 6 7 8 9 10 |
CREATE TABLE equipo ( codigo int(10) unsigned NOT NULL AUTO_INCREMENT, numeroserie varchar(100) DEFAULT NULL, tipo varchar(60) DEFAULT NULL, nombre varchar(150) DEFAULT NULL, fechacompra date DEFAULT NULL, uso varchar(150) DEFAULT NULL, version varchar(50) DEFAULT NULL, PRIMARY KEY (codigo) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 ROW_FORMAT=COMPACT |
Se trata de una tabla para inventario de equipos, que tiene como clave primaria (primary key) el campo «codigo», que será autoincremental. Es decir, cuando se inserte un registro en esta tabla, no habrá que establecer un valor para este campo, se generará automáticamente.
Código fuente C# para insertar un registro en una tabla
En el caso de que quisiéramos insertar un registro en una tabla MySQL (o cualquier otro motor de base de datos como Oracle, SQL Server, PostgreSQL, MariaDB, …), si no necesitamos obtener el identificativo del registro insertado, podemos usar el método ExecuteNonQuery(), que devolverá el número de registros afectados, que en un insert normal será 1.
Como ejemplo de este método, insertaremos un registro en la tabla anterior «equipo», y el método devolverá el número de registros afectados (1 sí el insert se ha ejecutado correctamente, 0 si ha habido algún error):
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 |
public Int insertarEquipo(string numeroserie, string tipo, string nombre, string version) { int numRegistros = 0; string sqlEjecutar = "insert into equipo (numeroserie, tipo, nombre, " + "fechacompra, version) " + "VALUES (@numeroserie, @tipo, @nombre, " + "@fechacompra, @version)"; try { MySqlCommand comandoSQL = new MySqlCommand(); conexionBD.Close(); comandoSQL.Connection = conexionBD; comandoSQL.CommandText = sqlEjecutar; comandoSQL.Parameters.Add("@numeroserie", MySqlDbType.String).Value = numeroserie; comandoSQL.Parameters.Add("@tipo", MySqlDbType.String).Value = tipo; comandoSQL.Parameters.Add("@nombre", MySqlDbType.String).Value = nombre; comandoSQL.Parameters.Add("@version", MySqlDbType.String).Value = version; comandoSQL.Parameters.Add("@fechacompra", MySqlDbType.DateTime).Value = DateTime.Now; conexionBD.Open(); numRegistros = comandoSQL.ExecuteNonQuery(); return numRegistros; } catch (MySqlException ex) { new EscribirLog("Error al añadir dispositivo [" + tipo + "]: " + ex.Message, true); return numRegistros; //0 si ha habido algún error } finally { conexionBD.Close(); } } |
El método anterior insertará un registro en la tabla «equipo» y devolverá 1 si se ha insertado correctamente, o bien 0 si ha habido algún error.
El método anterior usa una conexión a la BD, definida al principio de la clase con:
|
1 |
private MySqlConnection conexionBD; |
Y tendremos un método que conectará con el servidor de base de datos:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
public void conectarBD() { if (conexionBD != null) conexionBD.Close(); string connStr = String.Format("server={0};port={1};user id={2}; password={3}; " + "database={4}; pooling=true;" + "Allow Zero Datetime=False;Convert Zero Datetime=True", this.servidor, this.puerto, this.usuario, this.contrasena, this.bd); try { conexionBD = new MySqlConnection(connStr); new EscribirLog("Conectado a servidor BD " + this.servidor + " [" + this.bd + "]", false); } catch (MySqlException ex) { new EscribirLog("Error al conectar al servidor de BD " + this.servidor + " [" + this.bd + "] " + ex.Message, true); } finally { conexionBD.Close(); } } |
Código fuente C# para insertar un registro en una tabla y obtener el valor del campo clave primaria del registro insertado
Cuando insertamos un registro en una tabla y queremos obtener el valor de la clave primera de dicho registro, para seguir trabajando con él, usaremos el método ExecuteScalar. Este método devuelve un objeto con todos los datos del primer registro de la lista, entre ellos el campo clave primaria.
Por ejemplo, supongamos que necesitamos saber qué código se le ha asignado al equipo nuevo insertado para, tras insertarlo, agregar registros a otra tabla en maestro-detalle de las tareas del equipo. En este caso necesitaremos saber qué valor tiene el campo «codigo» de la tabla «equipo» del registro insertado.
Para ello podremos usar el siguiente código:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
public Int insertarEquipo(string numeroserie, string tipo, string nombre, string version) { int codigoRegistroInsertado = 0; string sqlEjecutar = "insert into equipo (numeroserie, tipo, nombre, " + "fechacompra, version) " + "VALUES (@numeroserie, @tipo, @nombre, " + "@fechacompra, @version); SELECT LAST_INSERT_ID()"; //Para SQL Server cambiar SELECT LAST_INSERT_ID() por SCOPE_IDENTITY() try { MySqlCommand comandoSQL = new MySqlCommand(); conexionBD.Close(); comandoSQL.Connection = conexionBD; comandoSQL.CommandText = sqlEjecutar; comandoSQL.Parameters.Add("@numeroserie", MySqlDbType.String).Value = numeroserie; comandoSQL.Parameters.Add("@tipo", MySqlDbType.String).Value = tipo; comandoSQL.Parameters.Add("@nombre", MySqlDbType.String).Value = nombre; comandoSQL.Parameters.Add("@version", MySqlDbType.String).Value = version; comandoSQL.Parameters.Add("@fechacompra", MySqlDbType.DateTime).Value = DateTime.Now; conexionBD.Open(); codigoRegistroInsertado = Convert.ToInt32(comandoSQL.ExecuteScalar()); return codigoRegistroInsertado; } catch (MySqlException ex) { new EscribirLog("Error al añadir dispositivo [" + tipo + "]: " + ex.Message, true); return codigoRegistroInsertado; //0 si ha habido algún error } finally { conexionBD.Close(); } } |
En este caso el código para insertar un registro es similar al anterior, pero con dos cambios importantes:
a) Por un lado, hemos insertado al final de la consulta SQL de INSERT, el texto:
; SELECT LAST_INSERT_ID()
Si usamos el motor de base de datos SQL Server, cambiaremos el texto anterior por
;SELECT SCOPE_IDENTITY()
b) Por otro lado, hemos cambiado el método ExecuteNonQuery por ExecuteScalar. De esta forma, se ejecutará la consulta SQL de insert, y a continuación se ejecutará el procedimiento «LAST_INSERT_ID()» que devolverá el valor del campo clave primaria del registro insertado. Este será el valor que devuelva el método insertarEquipo.
Por lo tanto, si ejecutamos el método insertarEquipo usando el método ExecuteScalar, de la siguiente forma:
|
1 2 3 4 5 6 7 8 9 10 11 |
int codigoRegistroNuevo = 0; codigoRegistroNuevo = insertarEquipo("SAS_PROYECTOA", "Portátil", "PALONSO", "10"); if (codigoRegistroNuevo > 0) { //Código a ejecutar si se ha insertado el registro //En "codigoRegistroNuevo" tendremos el valor del campo "codigo" del registro insertado } else { //Código a ejecutar si se ha producido un error al insertar el registro } |
En el ejemplo anterior de uso, en la variable codigoRegistroNuevo se almacenará el valor numérico del campo «codigo» de la tabla «equipo» del registro insertado. Con este valor podremos operar para realizar la acción que necesitemos.
