Skip to content

John McEleney / mailutils

Go to a project
Toggle navigation
Toggle navigation pinning
Commit 5130f6bc 5130f6bc60773a7adb1c0b04a8c29f8aa5ad173a by Sergey Poznyakoff
Options

Functionality merged into auth/sql.c

1 parent d4627cb0
Inline Side-by-side
Showing 4 changed files with 0 additions and 383 deletions
Makefile.in
Makefile
.deps
.libs
noinst_LIBRARIES = @BUILD_LIBMYSQL@
EXTRA_LIBRARIES = libmailMysql.a
libmailMysql_a_SOURCES = MySql.c
noinst_HEADERS = MySql.h
INCLUDES = -I$(top_srcdir)/include
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif
#include <stdio.h>
#include <stdlib.h>
#include <pwd.h>
#include <mailutils/error.h>
#ifdef HAVE_MYSQL
#ifdef HAVE_SHADOW_H
#include <shadow.h>
#endif /* HAVE_SHADOW_H */
#include <mysql/mysql.h>
#include "MySql.h"
extern void *xmalloc (size_t);
static char *
sql_expand_query (const char *query, const char *ustr)
{
char *p, *q, *res;
int len;
if (!query)
return NULL;
/* Compute resulting query length */
for (len = 0, p = (char *) query; *p; )
{
if (*p == '%')
{
if (p[1] == 'u')
{
len += strlen (ustr);
p += 2;
}
else if (p[1] == '%')
{
len++;
p += 2;
}
else
{
len++;
p++;
}
}
else
{
len++;
p++;
}
}
res = malloc (len + 1);
if (!res)
return res;
for (p = (char *) query, q = res; *p; )
{
if (*p == '%')
{
switch (*++p)
{
case 'u':
strcpy (q, ustr);
q += strlen (q);
p++;
break;
case '%':
*q++ = *p++;
break;
default:
*q++ = *p++;
}
}
else
*q++ = *p++;
}
*q = 0;
return res;
}
struct passwd *
getMpwnam (const char *username)
{
char *QueryStr = NULL;
MYSQL *m;
MYSQL_RES *res;
MYSQL_ROW row;
static struct passwd *tpw;
if (tpw)
{
free (tpw->pw_name);
free (tpw->pw_passwd);
free (tpw->pw_gecos);
free (tpw->pw_dir);
free (tpw->pw_shell);
}
m = mysql_init (0);
if (!m)
return NULL;
if (!mysql_real_connect (m, sql_host, sql_user, sql_passwd, sql_db, sql_port,
sql_socket, MFLAGS))
{
mu_error ("MySQL: connect failed: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
QueryStr = sql_expand_query (sql_getpwnam_query, username);
if (!QueryStr)
{
mysql_close (m);
return NULL;
}
if (mysql_query (m, QueryStr) != 0)
{
mu_error ("MySQL: query failed: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if ((res = mysql_store_result (m)) == NULL)
{
mu_error ("MySQL: can't store result: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if ((row = mysql_fetch_row (res)) == NULL)
{
mu_error ("MySQL: can't fetch row: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if (!tpw)
tpw = (struct passwd *)xmalloc (sizeof (struct passwd));
tpw->pw_name = xmalloc (strlen (row[0])+1);
strcpy (tpw->pw_name, row[0]);
tpw->pw_passwd = xmalloc (strlen (row[1])+1);
strcpy (tpw->pw_passwd, row[1]);
tpw->pw_uid = atoi (row[2]);
tpw->pw_gid = atoi (row[3]);
tpw->pw_gecos = xmalloc (strlen ("Mysql User")+1);
strcpy (tpw->pw_gecos, "Mysql User");
tpw->pw_dir = xmalloc (strlen (row[4])+1);
strcpy (tpw->pw_dir, row[4]);
tpw->pw_shell = xmalloc (strlen (row[5])+1);
strcpy (tpw->pw_shell, row[5]);
mysql_free_result (res);
mysql_close (m);
return tpw;
}
struct passwd *
getMpwuid (uid_t *puid)
{
char *QueryStr = NULL;
MYSQL *m;
MYSQL_RES *res;
MYSQL_ROW row;
static struct passwd *tpw;
char uidstr[64];
if (tpw)
{
free (tpw->pw_name);
free (tpw->pw_passwd);
free (tpw->pw_gecos);
free (tpw->pw_dir);
free (tpw->pw_shell);
}
m = mysql_init (0);
if (!m)
return NULL;
if (!mysql_real_connect (m, sql_host, sql_user, sql_passwd, sql_db, sql_port,
sql_socket, MFLAGS))
{
mu_error ("MySQL: connect failed: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
snprintf (uidstr, sizeof (uidstr), "%u", *puid);
QueryStr = sql_expand_query (sql_getpwuid_query, uidstr);
if (!QueryStr)
{
mysql_close (m);
return NULL;
}
if (mysql_query (m, QueryStr) != 0)
{
mu_error ("MySQL: query failed: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if ((res = mysql_store_result (m)) == NULL)
{
mu_error ("MySQL: can't store result: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if ((row = mysql_fetch_row (res)) == NULL)
{
mu_error ("MySQL: can't fetch row: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if (!tpw)
tpw = (struct passwd *)xmalloc (sizeof (struct passwd));
tpw->pw_name = xmalloc (strlen (row[0]+1));
strcpy (tpw->pw_name, row[0]);
tpw->pw_passwd = xmalloc (strlen (row[1])+1);
strcpy (tpw->pw_passwd, row[0]);
tpw->pw_uid = atoi (row[2]);
tpw->pw_gid = atoi (row[3]);
tpw->pw_gecos = xmalloc (strlen ("Mysql User")+1);
strcpy (tpw->pw_gecos, "Mysql User");
tpw->pw_dir = xmalloc (strlen (row[4])+1);
strcpy (tpw->pw_dir, row[4]);
tpw->pw_shell = xmalloc (strlen (row[5])+1);
strcpy (tpw->pw_shell, row[5]);
mysql_free_result (res);
mysql_close (m);
return tpw;
}
#ifdef HAVE_SHADOW_H
struct spwd *
getMspnam (const char *username)
{
char *QueryStr = NULL;
MYSQL *m;
MYSQL_RES *res;
MYSQL_ROW row;
static struct spwd *tpw;
if (tpw)
{
free (tpw->sp_namp);
free (tpw->sp_pwdp);
}
m = mysql_init (0);
if (!m)
return NULL;
if (!mysql_real_connect (m, sql_host, sql_user, sql_passwd, sql_db, sql_port,
sql_socket, MFLAGS))
{
mu_error ("MySQL: connect failed: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
QueryStr = sql_expand_query (sql_getpass_query, username);
if (!QueryStr)
{
mysql_close (m);
return NULL;
}
if (mysql_query (m, QueryStr) != 0)
{
mu_error ("MySQL: query failed: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if ((res = mysql_store_result (m)) == NULL)
{
mu_error ("MySQL: can't store result: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if ((row = mysql_fetch_row (res)) == NULL)
{
mu_error ("MySQL: can't fetch row: %s", mysql_error (m));
mysql_close (m);
return NULL;
}
if (!tpw)
tpw = (struct spwd *)xmalloc (sizeof (struct spwd));
tpw->sp_namp = xmalloc (strlen (username)+1);
strcpy (tpw->sp_namp, username);
tpw->sp_pwdp = xmalloc (strlen (row[0])+1);
strcpy (tpw->sp_pwdp, row[0]);
tpw->sp_lstchg = 11428;
tpw->sp_min = 0;
tpw->sp_max = 99999;
tpw->sp_warn = 7;
mysql_free_result (res);
mysql_close (m);
return tpw;
}
#endif /* HAVE_SHADOW_H */
#endif /* HAVE_MYSQL */
#include <config.h>
#ifdef HAVE_MYSQL
extern char *sql_getpwnam_query;
extern char *sql_getpass_query;
extern char *sql_getpwuid_query;
extern char *sql_host;
extern char *sql_user;
extern char *sql_passwd;
extern char *sql_db;
extern char *sql_socket;
extern int sql_port;
struct passwd *getMpwnam (const char *username);
struct passwd *getMpwuid (uid_t *puid);
struct spwd *getMspnam (const char *username);
#define MHOST NULL /* Hostname to connect to. NULL for UNIX
socket connection */
#define MPORT 0 /* Port number to connect to. 0 means default
MySQL port (3300) */
#define MSOCKET NULL /* Socket name to use. Valid only if
connecting via UNIX sockets */
#define MFLAGS 0 /* Special user flags. It is safe to leave
this untouched */
#define MUSER "accounts" /* Username for mysql access */
#define MPASS "yurpass" /* Password for mysql access */
#define MDB "accounts" /* Database Name */
#endif /* HAVE_MYSQL */